Github user GJL commented on the issue: https://github.com/apache/flink/pull/5545 The test relies on being able to set setParallelism on a non-parallel source: `DataStream<Integer> input1 = env.fromElements(1, 2, 3, 4).setMaxParallelism(128);`
---
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5545 The test relies on being able to set setParallelism on a non-parallel source: `DataStream<Integer> input1 = env.fromElements(1, 2, 3, 4).setMaxParallelism(128);`
---