You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2018/10/31 10:24:29 UTC
[flink] 03/25: [FLINK-7811] Make Long literal explicit to support
Scala 2.12
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 <al...@gmail.com>
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)