forked from D-Net/dnet-hadoop
added check to avoid NPE when checking the organization country
This commit is contained in:
parent
0704e186f6
commit
99ac5bab46
|
@ -78,6 +78,8 @@ public class GetDatasourceFromCountry implements Serializable {
|
||||||
Encoders.bean(Organization.class))
|
Encoders.bean(Organization.class))
|
||||||
.filter(
|
.filter(
|
||||||
(FilterFunction<Organization>) o -> !o.getDataInfo().getDeletedbyinference() &&
|
(FilterFunction<Organization>) o -> !o.getDataInfo().getDeletedbyinference() &&
|
||||||
|
o.getCountry() != null &&
|
||||||
|
o.getCountry().getClassid() != null &&
|
||||||
o.getCountry().getClassid().length() > 0 &&
|
o.getCountry().getClassid().length() > 0 &&
|
||||||
o.getCountry().getClassid().equals(country));
|
o.getCountry().getClassid().equals(country));
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue