Flink 采用了一種稱為任務鏈的優化技術，可以在特定條件下減少本地通信的開銷。為了滿足任務鏈的要求，必須將兩個或多個算子設為相同的并行度，并通過本地轉發（local forward）的方式進行連接，相同并行度的 one-to-one 操作，Flink 這樣相連的算子鏈接在一起形成 一個task，原來的算子成為里面的 subtask，同而共享相同的slot。

任務鏈的手動配置
①全部不合成任務鏈
env.disableOperatorChaining()

②單個算子不參與合成任務鏈
.disableChaining()

③從單個算子開啟一個新的任務鏈
.startNewChain()

總結

以上是生活随笔為你收集整理的Flink任务链Operator Chains的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。