[hotfix] minor: make type explicit to allow Scala test to compile in …

…Eclipse
todd5167 · Apr 27, 2016 · 8ad264d · 8ad264d
1 parent 16059ea
commit 8ad264d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-scala/src/test/scala/org/apache/flink/api/scala/extensions/base/AcceptPFTestBase.scala b/flink-scala/src/test/scala/org/apache/flink/api/scala/extensions/base/AcceptPFTestBase.scala
@@ -29,7 +29,7 @@ private[extensions] abstract class AcceptPFTestBase extends TestLogger with JUni
 
   private val env = ExecutionEnvironment.getExecutionEnvironment
 
-  protected val tuples = env.fromElements(1 -> "hello", 2 -> "world")
+  protected val tuples = env.fromElements(new Integer(1) -> "hello", new Integer(2) -> "world")
   protected val caseObjects = env.fromElements(KeyValuePair(1, "hello"), KeyValuePair(2, "world"))
 
   protected val groupedTuples = tuples.groupBy(_._1)