ShufflePartitioner: public int selectChannel(SerializationDelegate<StreamRecord<T>> record) { return random.nextInt(numberOfChannels); }
RebalancePartitioner public int selectChannel(SerializationDelegate<StreamRecord<T>> record) { nextChannelToSendTo = (nextChannelToSendTo + 1) % numberOfChannels; return nextChannelToSendTo; } 一个随机,一个严格 round-robin。 Best, Kezhu Wang On March 15, 2021 at 22:02:33, 赢峰 (si_ji_f...@163.com) wrote: Flink 中 shuffle Partitioner 和 rebalance partitoner 有什么区别?