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

Commit 5fd6921

Browse files
Bugfix in OWLReaderDataSet example
Added missing serializer for UnmodifiableCollection
1 parent 42297ef commit 5fd6921

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/owl/OWLReaderDataSet.scala

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
11
package net.sansa_stack.examples.flink.owl
22

3-
import scala.collection.mutable
3+
import de.javakaffee.kryoserializers.UnmodifiableCollectionsSerializer
44

5+
import scala.collection.mutable
56
import net.sansa_stack.owl.flink.owl._
67
import org.apache.flink.api.scala.ExecutionEnvironment
78

@@ -24,6 +25,11 @@ object OWLReaderDataSet {
2425
println(".============================================.")
2526

2627
val env = ExecutionEnvironment.getExecutionEnvironment
28+
// scalastyle:off classforname
29+
env.getConfig.addDefaultKryoSerializer(
30+
Class.forName("java.util.Collections$UnmodifiableCollection"),
31+
classOf[UnmodifiableCollectionsSerializer])
32+
// scalastyle:on classforname
2733

2834
val dataSet = syntax match {
2935
case "fun" => env.owl(Syntax.FUNCTIONAL)(input)

0 commit comments

Comments
 (0)