-
- flink cli 解析本地环境配置,启动
ApplicationMaster
- 在
ApplicationMaster
中启动JobManager
- 在
ApplicationMaster
中启动YarnFlinkResourceManager
YarnFlinkResourceManager
给JobManager
发送注册信息YarnFlinkResourceManager
注册成功后,JobManager
给YarnFlinkResourceManager
发送注册成功信息YarnFlinkResourceManage
知道自己注册成功后像ResourceManager
申请和TaskManager
数量对等的 container- 在container中启动
TaskManager
TaskManager
将自己注册到JobManager
中
接下来便是程序的提交和运行。
- flink cli 解析本地环境配置,启动
JobManager
负责接收 flink 的作业,调度 task,收集 job 的状态、jar 包管理,checkpoint 的协调和发起,管理 TaskManagers。- 算子:flink 的一个 operator 代表一个最顶级的 API接口。对于streaming,在 DataStream 上做诸如 map/reduce/keyBy 等操作均会生成一个算子。
Apache Flink - 补充
猜你喜欢
转载自www.cnblogs.com/ooffff/p/9476032.html
今日推荐
周排行