Github user GJL commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4896#discussion_r158259995
  
    --- Diff: 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.java
 ---
    @@ -55,6 +55,7 @@ public static void main(String[] args) throws Exception {
                final StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
                env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
                env.getConfig().setGlobalJobParameters(params);
    +           env.setParallelism(1);
    --- End diff --
    
    Is this strictly needed? It's not a Unit or ITCase and the example seems to 
work without this line.


---

Reply via email to