The `ExecutionMode` defines the data exchange between producers and consumers. When using `BATCH`, then the producers (e.g. input for a reduce operation) first need to finish before the consumer is started. In `PIPELINED` mode, the consumer will start as soon as a single producer has produced some consumable data.
The test job contains a shuffle operation (between mapper and reducer) which is affected by this setting. [ Full content available at: https://github.com/apache/flink/pull/6751 ] This message was relayed via gitbox.apache.org for [email protected]
