This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit e90f78892a6826821c0c49ed050853e190114224 Author: Aljoscha Krettek <[email protected]> AuthorDate: Tue Oct 2 10:17:25 2018 +0200 [FLINK-7811] Make Long literal explicit to support Scala 2.12 --- .../scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala index 7b7dde5..f65caa4 100644 --- a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala +++ b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala @@ -60,7 +60,7 @@ class DataStreamTest extends AbstractTestBase { val dataStream2 = env.generateSequence(0, 0).name("testSource2") .keyBy(x=>x) - .reduce((x, y) => 0) + .reduce((x, y) => 0L) .name("testReduce") assert("testReduce" == dataStream2.getName)
