Merge pull request #16 from SANSA-Stack/release_update

patrickwestphal · web-flow · commit 71b1bf1d947c · 2019-12-16T23:47:18.000+01:00
Bugfix in ForwardRuleReasonerRDFS
diff --git a/sansa-inference-flink/src/main/scala/net/sansa_stack/inference/flink/forwardchaining/ForwardRuleReasonerRDFS.scala b/sansa-inference-flink/src/main/scala/net/sansa_stack/inference/flink/forwardchaining/ForwardRuleReasonerRDFS.scala
@@ -318,7 +318,7 @@ class ForwardRuleReasonerRDFS(env: ExecutionEnvironment) extends ForwardRuleReas
 
       val additionalTripleRDDs = mutable.Seq(rdfs4, rdfs6, rdfs8_10, rdfs12)
 
-      allTriples = env.union(Seq(allTriples) ++ additionalTripleRDDs).distinct()
+      allTriples = env.union(Seq(allTriples) ++ additionalTripleRDDs).distinct(_.hashCode)
     }
 
     logger.info(

Original file line number	Diff line number	Diff line change
`@@ -318,7 +318,7 @@ class ForwardRuleReasonerRDFS(env: ExecutionEnvironment) extends ForwardRuleReas`
`318`	`318`
`319`	`319`	`val additionalTripleRDDs = mutable.Seq(rdfs4, rdfs6, rdfs8_10, rdfs12)`
`320`	`320`
`321`		`- allTriples = env.union(Seq(allTriples) ++ additionalTripleRDDs).distinct()`
	`321`	`+ allTriples = env.union(Seq(allTriples) ++ additionalTripleRDDs).distinct(_.hashCode)`
`322`	`322`	`}`
`323`	`323`
`324`	`324`	`logger.info(`