1
0
Fork 0

bug fix: ids in self mergerels are not marked deletedbyinference=true

This commit is contained in:
miconis 2021-04-12 15:56:22 +02:00
parent 11b22b2d23
commit d442e25cbc
1 changed files with 1 additions and 0 deletions

View File

@ -91,6 +91,7 @@ public class SparkUpdateEntity extends AbstractSparkAction {
final JavaPairRDD<String, String> mergedIds = rel final JavaPairRDD<String, String> mergedIds = rel
.where("relClass == 'merges'") .where("relClass == 'merges'")
.where("source != target")
.select(rel.col("target")) .select(rel.col("target"))
.distinct() .distinct()
.toJavaRDD() .toJavaRDD()