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 62ef547f2fc7f690bafaa4989166ff14fc471db5 Author: Aljoscha Krettek <[email protected]> AuthorDate: Sat Oct 20 07:50:10 2018 +0200 [FLINK-7811] Make IterateExample.Bound final so it can be used in withinBound() With Scala 2.12, the ClosureCleaner will complain that the filter function that uses withinBound() is not serializable. The reason is that when "Bound" is not final it will serialize it with the closure, wich includes IterateExample. --- .../flink/streaming/scala/examples/iteration/IterateExample.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/iteration/IterateExample.scala b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/iteration/IterateExample.scala index ecbf7c5..1fa3ace 100644 --- a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/iteration/IterateExample.scala +++ b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/iteration/IterateExample.scala @@ -41,7 +41,7 @@ import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironm */ object IterateExample { - private val Bound = 100 + private final val Bound = 100 def main(args: Array[String]): Unit = { // Checking input parameters
