Merge branch 'release/0.7.1'

Author: LorenzBuehmann

pom.xml

@@ -6,7 +6,7 @@
 	<parent>
 		<groupId>net.sansa-stack</groupId>
 		<artifactId>sansa-parent</artifactId>
-		<version>0.6.0</version>
+		<version>0.7.1</version>
 	</parent>
 
 	<artifactId>sansa-inference-parent_2.11</artifactId>

sansa-inference-common/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <artifactId>sansa-inference-parent_2.11</artifactId>
     <groupId>net.sansa-stack</groupId>
-    <version>0.6.0</version>
+    <version>0.7.1</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
   <artifactId>sansa-inference-common_${scala.binary.version}</artifactId>
@@ -79,11 +79,6 @@
       <groupId>org.apache.calcite</groupId>
       <artifactId>calcite-core</artifactId>
     </dependency>
-    <dependency>
-      <groupId>com.google.protobuf</groupId>
-      <artifactId>protobuf-java</artifactId>
-      <version>3.5.0</version>
-    </dependency>
 
     <!-- Scopt CLI API-->
     <dependency>

sansa-inference-flink/pom.xml

@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>net.sansa-stack</groupId>
 		<artifactId>sansa-inference-parent_2.11</artifactId>
-		<version>0.6.0</version>
+		<version>0.7.1</version>
 		<relativePath>../pom.xml</relativePath>
 	</parent>
 	<artifactId>sansa-inference-flink_${scala.binary.version}</artifactId>

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(

sansa-inference-flink/src/main/scala/net/sansa_stack/inference/flink/forwardchaining/TransitiveReasoner.scala

@@ -7,10 +7,9 @@ import org.apache.flink.api.common.typeinfo.TypeInformation
 import org.apache.flink.api.scala.{DataSet, _}
 import org.apache.flink.util.Collector
 import org.apache.jena.graph.{Node, Triple}
-import org.apache.jena.sparql.util.NodeComparator
 
-import net.sansa_stack.inference.flink.utils.NodeKey
 import net.sansa_stack.inference.utils.Profiler
+import net.sansa_stack.rdf.flink.utils.NodeKey
 
 /**
   * An engine to compute the transitive closure (TC) for a set of triples given in several datastructures.