【Flink-API】數據交換和Redistribute

在Flink中，是TaskManager而不是task在網絡上交換數據.比如，處於同一個TM內的task,他們之間的數據交換是在- -個網絡連接(TaskManager 創建並維護)上基於多路複用的。 ExecutionGraph:執行圖是- -個包含job計算的邏輯的數據結構.它包含節點(ExecutionVertex, 表示計算任務),以及中間結果(IntermnediateResultPar

>>阅读原文<<