@StephanEwen Thanks for your suggestion. I've made an update to it. For further optimization, the one-channel-only selector which always returns just `0`, can be used instead of using `ShufflePartitioner` or `RebalancePartitioner` where outputs have only one channel.
It seems that we have a `ForwardPartitioner` already which always returns 0. And it could be an optimization in the process during building the job graph, maybe in another new issue. [ Full content available at: https://github.com/apache/flink/pull/6544 ] This message was relayed via gitbox.apache.org for [email protected]
