Actually, this is a copy of `org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner` which is in the `flink-streaming-java` submodule, though. And in general it is good to cache this rather than building a new array for every record...
Using `returnChannel.length == numberOfOutputChannels` makes sense though - @zhijiangW can you also create a hotfix commit changing this in `org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner`? [ Full content available at: https://github.com/apache/flink/pull/6417 ] This message was relayed via gitbox.apache.org for [email protected]
