發(fā)送到下游對(duì)應(yīng)的第一個(gè)任務(wù)，保證上游算子數(shù)量度一致，即下游算子與下游算子是1:1的關(guān)系?

源碼解讀

圖解

在上下游的算子沒(méi)有指定分區(qū)器的情況下，如果上下游的算子精度一致，則使用ForwardPartitioner，否則使用RebalancePartitioner，對(duì)于ForwardPartitioner，必須保證上下游的算子精度一致，否則會(huì)引發(fā)異常

效果

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

示例代碼