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/