Skip to content
This repository was archived by the owner on Oct 8, 2020. It is now read-only.

Commit d4e7fa3

Browse files
Fix test computation.
1 parent 8620a23 commit d4e7fa3

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

sansa-inference-flink/src/test/scala/net/sansa_stack/inference/flink/RDFGraphTestCase.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package net.sansa_stack.inference.flink
22

3+
import java.util
34
import java.util.Comparator
45

56
import com.google.common.collect.ComparisonChain
@@ -49,7 +50,7 @@ class RDFGraphTestCase(mode: TestExecutionMode) extends MultipleProgramsTestBase
4950
RDFTriple("s1", "p1", "o3")
5051
)
5152

52-
TestBaseUtils.compareResultCollections(result.asJava, expected.asJava, new Comparator[RDFTriple] {
53+
TestBaseUtils.compareResultCollections(new util.ArrayList(result.asJava), new util.ArrayList(expected.asJava), new Comparator[RDFTriple] {
5354
override def compare(t1: RDFTriple, t2: RDFTriple): Int =
5455
ComparisonChain.start()
5556
.compare(t1.s, t2.s)

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@ import net.sansa_stack.inference.flink.forwardchaining.{ForwardRuleReasoner, For
44
import org.apache.flink.api.scala.ExecutionEnvironment
55
import org.junit.runner.RunWith
66
import org.junit.runners.Parameterized
7-
import net.sansa_stack.inference.flink.forwardchaining.{ForwardRuleReasoner, ForwardRuleReasonerRDFS}
87
import org.scalatest.{BeforeAndAfterAll, Suite}
98

109
/**
@@ -17,8 +16,7 @@ trait SharedRDFSReasonerContext extends BeforeAndAfterAll with ReasonerContextPr
1716
self: Suite =>
1817

1918
@transient private var _reasoner: ForwardRuleReasonerRDFS = _
20-
21-
val reasoner: ForwardRuleReasoner = _reasoner
19+
def reasoner: ForwardRuleReasoner = _reasoner
2220

2321
@transient private var _env: ExecutionEnvironment = _
2422
def env: ExecutionEnvironment = _env
@@ -27,6 +25,7 @@ trait SharedRDFSReasonerContext extends BeforeAndAfterAll with ReasonerContextPr
2725
override def beforeAll(): Unit = {
2826
super.beforeAll()
2927
_env = ExecutionEnvironment.getExecutionEnvironment
28+
_env.getConfig.disableSysoutLogging()
3029
_reasoner = new ForwardRuleReasonerRDFS(env)
3130
}
3231
}

0 commit comments

Comments
 (0)