[scala] Fix TupleSerializerTest for corrected CaseClassSerializer

shuttie · Dec 5, 2014 · 979837a · 979837a
1 parent 3470b37
commit 979837a
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTest.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTest.scala
@@ -17,6 +17,8 @@
  */
 package org.apache.flink.api.scala.runtime
 
+import java.util
+
 import org.apache.flink.api.java.typeutils.TupleTypeInfoBase
 import org.apache.flink.api.java.typeutils.runtime.AbstractGenericTypeSerializerTest._
 import org.apache.flink.api.common.typeinfo.TypeInformation
@@ -154,11 +156,13 @@ class TupleSerializerTest {
     val b5 = new Book(Long.MaxValue, "Winnign a prize for creative test strings", 0xBADF00)
     val b6 = new Book(-2L, "Distributed Systems", 0xABCDEF0123456789L)
 
-    val list = List("A", "B", "C", "D", "E")
-    val ba1 = new BookAuthor(976243875L, list.asJava, "Arno Nym")
+    // We need to use actual java Lists here, to make them serializable by the GenericSerializer
+    val list = new util.LinkedList[String]()
+    list.addAll(List("A", "B", "C", "D", "E").asJava)
+    val ba1 = new BookAuthor(976243875L, list, "Arno Nym")
 
-    val list2 = List[String]()
-    val ba2 = new BookAuthor(987654321L, list2.asJava, "The Saurus")
+    val list2 = new util.LinkedList[String]()
+    val ba2 = new BookAuthor(987654321L, list2, "The Saurus")
 
     val testTuples = Array(
       (a, b1, o1, ba1, co1),