diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java index dcf5cec..8891448 100644 --- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java +++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java @@ -77,11 +77,7 @@ public class SelectEoscResultsJobStep1 implements Serializable { .readPath(spark, inputPath, inputClazz) .filter( (FilterFunction) r -> !r.getDataInfo().getDeletedbyinference() && !r.getDataInfo().getInvisible() - && (r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")) || r - .getCollectedfrom() - .stream() - .anyMatch(cf -> cf.getValue().equalsIgnoreCase("B2FIND")))) - + && r.getContext().stream().anyMatch(c -> c.getId().equals("eosc"))) .map( (MapFunction) r -> (Result) ResultMapper .map(r, communityMap),