RescalePartitioner，RESCALE分區(qū)，使用的也是輪詢算法，只是將數(shù)據(jù)發(fā)送到接下來的幾個運行的任務(wù)中的部分任務(wù)中，本質(zhì)上，當(dāng)發(fā)送者任務(wù)數(shù)量和接受者任務(wù)數(shù)量不同時， rescale分區(qū)提供了一種輕量級的負(fù)載均衡策略。如果接收者任務(wù)的數(shù)量是發(fā)送者任務(wù)數(shù)量的倍數(shù)時，rescale操作將會更高的效率。

圖解

Rebalance和rescale的根本區(qū)別在于任務(wù)之間連接的機制不同。rebalance()將針對所有發(fā)送者任務(wù)和所有接收者任務(wù)之間建立通信通道，而 rescale() 格式針對每個一個任務(wù)的一部分任務(wù)之間建立通信通道。

效果

編寫Flink程序，接收socket的單詞數(shù)據(jù)，把每個字符串廣播到每個分區(qū)。

示例代碼