Repository: flink Updated Branches: refs/heads/master b23c37eef -> baebbabfc
[FLINK-7609][examples] Adjust WindowWordCount default window configuration values This closes #4662. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/baebbabf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/baebbabf Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/baebbabf Branch: refs/heads/master Commit: baebbabfc6913598122fc5df8645097172bd9e65 Parents: 012024e Author: Bowen Li <bowenl...@gmail.com> Authored: Fri Sep 8 13:44:16 2017 -0700 Committer: zentol <ches...@apache.org> Committed: Tue Sep 19 11:06:52 2017 +0200 ---------------------------------------------------------------------- .../flink/streaming/examples/windowing/WindowWordCount.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/baebbabf/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java ---------------------------------------------------------------------- diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java index 9b747f0..b454f48 100644 --- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java +++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java @@ -68,8 +68,8 @@ public class WindowWordCount { // make parameters available in the web interface env.getConfig().setGlobalJobParameters(params); - final int windowSize = params.getInt("window", 250); - final int slideSize = params.getInt("slide", 150); + final int windowSize = params.getInt("window", 10); + final int slideSize = params.getInt("slide", 5); DataStream<Tuple2<String, Integer>> counts = // split up the lines in pairs (2-tuples) containing: (word,1)
