Repository: flink Updated Branches: refs/heads/master 16059ea20 -> 8ad264d0f
[hotfix] minor: make type explicit to allow Scala test to compile in Eclipse Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ad264d0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8ad264d0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8ad264d0 Branch: refs/heads/master Commit: 8ad264d0f9f9cc89de6f95a93ec9c2b835dd591b Parents: 16059ea Author: mjsax <mj...@apache.org> Authored: Wed Apr 27 13:28:57 2016 +0200 Committer: mjsax <mj...@apache.org> Committed: Wed Apr 27 13:28:57 2016 +0200 ---------------------------------------------------------------------- .../apache/flink/api/scala/extensions/base/AcceptPFTestBase.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/8ad264d0/flink-scala/src/test/scala/org/apache/flink/api/scala/extensions/base/AcceptPFTestBase.scala ---------------------------------------------------------------------- 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 index c2e13fe..f9ce3b8 100644 --- 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)