Flink运行时架构主要包括四个不同的组件,它们会在运行流处理应用程序时协同工作:作业管理器(JobManager)、资源管理器(ResourceManager)、任务管理器(TaskManager),以及分发器(Dispatcher)。因为Flink是用Java和Scala实现的,所以所有组件都会运行在Java虚拟机上。每个组件的职责如下
作业管理器(JobManager)

博主解析:

资源管理器(ResourceManager)

博主解析:

任务管理器(TaskManager)

博主解析:

分发器(Dispatcher)

博主解析:

整个Flink Job运行过程图

Flink Job提交流程到背压到TaskManager里面的slot,任务链等详情

- 本文作者: xubatian
- 本文链接: http://xubatian.cn/Flink-原理与实现-Flink运行时的组件/
- 版权声明: 本博客所有文章除特别声明外均为原创,采用 CC BY 4.0 CN协议 许可协议。转载请注明出处:https://www.xubatian.cn/

故人的博客
IT周的博客
大胖胖的笔记
常瑞的部落落
Fortune博客
星空下的YZY
BOBL技术博客