Flink Task的數據交換機制概述

Flink的數據交換機制在設計時遵循兩個基本原則: 數據交換的控制流(例如,爲初始化數據交換而發出的消息)是由接收端發起的 數據交換的數據流(例如,在網絡中實際傳輸的數據被抽象爲IntermediateResult的概念)是可插拔的 數據交換也涉及到了一些角色,包括: JobManager:master節點,負責任務調度,異常恢復,任務協調,並且通過ExecutionGraph這樣的數據結構來保存
相關文章
相關標籤/搜索