You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sj...@apache.org on 2021/11/16 21:40:16 UTC
[flink] 05/11: [FLINK-24635][examples] Fix deprecations in window join example
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 <sj...@gmail.com>
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)