Bug fix in flink.inference.RDFGraphInference

patrickwestphal · patrickwestphal · commit f8c327b9ea06 · 2018-12-10T14:25:35.000+01:00
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/inference/RDFGraphInference.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/inference/RDFGraphInference.scala
@@ -91,9 +91,6 @@ object RDFGraphInference {
     println(s"|G_inf| = ${inferredGraph.size()}")
 
     val jn = if (jobName.isEmpty) s"RDF Graph Inference ($profile)" else jobName
-
-    // run the program
-    env.execute(jn)
   }
 
   // the config object

Original file line number	Diff line number	Diff line change
`@@ -91,9 +91,6 @@ object RDFGraphInference {`
`91`	`91`	`println(s"\|G_inf\| = ${inferredGraph.size()}")`
`92`	`92`
`93`	`93`	`val jn = if (jobName.isEmpty) s"RDF Graph Inference ($profile)" else jobName`
`94`		`-`
`95`		`- // run the program`
`96`		`- env.execute(jn)`
`97`	`94`	`}`
`98`	`95`
`99`	`96`	`// the config object`