Looking at org.apache.flink.runtime.operators.shipping.OutputEmitter,
shipping strategies FORWARD, PARTITION_RANDOM, and
PARTITION_FORCED_REBALANCE all call a local round-robin partitioning
function. I'd like to patch this so that the round-robin count starts at
the local task index, but shouldn't the FORWARD strategy be to always
partition to the local task index ("forwarding the data locally in memory")?https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/operators/shipping/OutputEmitter.java Greg
