diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java index 5c02498..ec729b8 100644 --- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java +++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java @@ -82,7 +82,8 @@ public class SparkSelectSubset implements Serializable { .readPath(spark, inputPath + "/relation", Relation.class) .filter( (FilterFunction) r -> !r.getDataInfo().getDeletedbyinference() - && !removeSet.contains(r.getRelClass())); + && !removeSet.contains(r.getRelClass()) && + !r.getRelType().equals("resultService")); Dataset resultIds = Utils .readPath(spark, outputPath + "/original/publication", Publication.class)