This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit cf8053e8bc4590ec84c2a204f856b3807baed594 Author: sjwiesman <[email protected]> AuthorDate: Mon Nov 15 14:49:55 2021 -0600 [FLINK-24635][examples] Fix deprecations in window join example --- .../java/org/apache/flink/streaming/examples/join/WindowJoin.java | 1 - .../org/apache/flink/streaming/scala/examples/join/WindowJoin.scala | 4 +--- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/join/WindowJoin.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/join/WindowJoin.java index 538ab98..ef33a58 100644 --- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/join/WindowJoin.java +++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/join/WindowJoin.java @@ -44,7 +44,6 @@ import org.apache.flink.streaming.examples.join.WindowJoinSampleData.SalarySourc * <p>The example uses a built-in sample data generator that generates the streams of pairs at a * configurable rate. */ -@SuppressWarnings("serial") public class WindowJoin { // ************************************************************************* diff --git a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/join/WindowJoin.scala b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/join/WindowJoin.scala index 3793a28..607ca04 100644 --- a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/join/WindowJoin.scala +++ b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/join/WindowJoin.scala @@ -19,7 +19,6 @@ package org.apache.flink.streaming.scala.examples.join import org.apache.flink.api.java.utils.ParameterTool -import org.apache.flink.streaming.api.TimeCharacteristic import org.apache.flink.streaming.api.scala._ import org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows import org.apache.flink.streaming.api.windowing.time.Time @@ -49,7 +48,7 @@ object WindowJoin { // Program // ************************************************************************* - def main(args: Array[String]) { + def main(args: Array[String]): Unit = { // parse the parameters val params = ParameterTool.fromArgs(args) val windowSize = params.getLong("windowSize", 2000) @@ -61,7 +60,6 @@ object WindowJoin { // obtain execution environment, run this example in "ingestion time" val env = StreamExecutionEnvironment.getExecutionEnvironment - env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime) // make parameters available in the web interface env.getConfig.setGlobalJobParameters(params)
