Flink conformance test clean up

Author: LorenzBuehmann

sansa-inference-flink/src/test/scala/net/sansa_stack/inference/flink/conformance/OWLHorstConformanceTest.scala

@@ -22,17 +22,15 @@ class OWLHorstConformanceTest
 
   override def computeInferredModel(triples: mutable.HashSet[Triple]): Model = {
     // distribute triples
-    val triplesRDD = env.fromCollection(triples)
+    val triplesDS = env.fromCollection(triples)
 
     // create graph
-    val graph = RDFGraph(triplesRDD)
+    val graph = RDFGraph(triplesDS)
 
     // compute inferred graph
     val inferredGraph = reasoner.apply(graph)
 
-    inferredGraph.triples.print()
-
-    // convert to JENA model
+    // convert to Jena model
     val inferredModel = RDFGraphWriter.convertToModel(inferredGraph)
 
     inferredModel

sansa-inference-flink/src/test/scala/net/sansa_stack/inference/flink/conformance/RDFSConformanceTest.scala

@@ -11,7 +11,7 @@ import net.sansa_stack.inference.flink.data.{RDFGraph, RDFGraphWriter}
 import net.sansa_stack.test.conformance.RDFSConformanceTestBase
 
 /**
-  * The class is to test the conformance of each materialization rule of RDFS(simple) entailment.
+  * The class is used to check the conformance of each materialization rule of RDFS(simple) entailment.
   *
   * @author Lorenz Buehmann
   *
@@ -22,17 +22,15 @@ class RDFSConformanceTest
 
   override def computeInferredModel(triples: mutable.HashSet[Triple]): Model = {
     // distribute triples
-    val triplesRDD = env.fromCollection(triples)
+    val triplesDS = env.fromCollection(triples)
 
     // create graph
-    val graph = RDFGraph(triplesRDD)
+    val graph = RDFGraph(triplesDS)
 
     // compute inferred graph
     val inferredGraph = reasoner.apply(graph)
 
-    inferredGraph.triples.print()
-
-    // convert to JENA model
+    // convert to Jena model
     val inferredModel = RDFGraphWriter.convertToModel(inferredGraph)
 
     inferredModel

sansa-inference-flink/src/test/scala/net/sansa_stack/inference/flink/conformance/SharedOWLHorstReasonerContext.scala

@@ -1,14 +1,13 @@
 package net.sansa_stack.inference.flink.conformance
 
-import net.sansa_stack.inference.flink.forwardchaining.ForwardRuleReasoner
-import org.apache.flink.api.scala.ExecutionEnvironment
 import org.junit.runner.RunWith
 import org.junit.runners.Parameterized
+import org.scalatest.Suite
+
 import net.sansa_stack.inference.flink.forwardchaining.ForwardRuleReasonerOWLHorst
-import org.scalatest.{BeforeAndAfterAll, Suite}
 
 /**
-  * Test context to share an RDFS reasoner.
+  * Test context to share an OWL Horst reasoner.
   *
   * @author Lorenz Buehmann
   */

sansa-inference-flink/src/test/scala/net/sansa_stack/inference/flink/conformance/SharedReasonerContext.scala

@@ -3,6 +3,7 @@ package net.sansa_stack.inference.flink.conformance
 import net.sansa_stack.rdf.common.kryo.jena.JenaKryoSerializers.{NodeSerializer, TripleSerializer}
 import org.apache.flink.api.scala.ExecutionEnvironment
 import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration
+import org.apache.flink.test.util.MiniClusterWithClientResource
 import org.apache.jena.graph.{Node, Triple}
 import org.scalatest.{BeforeAndAfterAll, Suite}
 
@@ -26,6 +27,13 @@ trait SharedReasonerContext[R <: ForwardRuleReasoner]
 
   override def beforeAll(): Unit = {
     super.beforeAll()
+
+    val miniClusterResource = new MiniClusterWithClientResource(
+      new MiniClusterResourceConfiguration.Builder()
+        .setNumberTaskManagers(1)
+        .setNumberSlotsPerTaskManager(DEFAULT_PARALLELISM)
+        .build)
+
     _env = ExecutionEnvironment.getExecutionEnvironment
     _env.setParallelism(4)
     _env.getConfig.disableSysoutLogging()

sansa-inference-flink/src/test/scala/net/sansa_stack/inference/flink/rules/TransitivityRuleTest.scala

@@ -10,7 +10,7 @@ import net.sansa_stack.inference.flink.data.{RDFGraph, RDFGraphWriter}
 import net.sansa_stack.inference.flink.forwardchaining.ForwardRuleReasonerRDFS
 
 /**
-  * A forward chaining implementation of the RDFS entailment regime.
+  * Test class to check transitivity chain rule is applied correctly in the RDFS reasoner.
   *
   * @author Lorenz Buehmann
   */