Flink Task的数据交换机制概述

Flink的数据交换机制在设计时遵循两个基本原则: 数据交换的控制流(例如,为初始化数据交换而发出的消息)是由接收端发起的 数据交换的数据流(例如,在网络中实际传输的数据被抽象为IntermediateResult的概念)是可插拔的 数据交换也涉及到了一些角色,包括: JobManager:master节点,负责任务调度,异常恢复,任务协调,并且通过ExecutionGraph这样的数据结构来保存
相关文章
相关标签/搜索