Wait a minute here.
```
emit(record, new int[] { rng.nextInt(numChannels) });
```
@NicoK is an actual performance regression. Creating a single element int array
(once per every record!) actually reduces the throughput by about 10%-20%
(tested during one of the hackathons). Please revert to using
`copyFromSerializerToTargetChannel(rng.nextInt(numChannels))`
[ Full content available at: https://github.com/apache/flink/pull/6417 ]
This message was relayed via gitbox.apache.org for [email protected]
