
1 和client的交互
客户端负责将任务提交到集群,与 JobManager 构建 Akka 连接,然后将任务提交到 JobManager,通过和 JobManager 之间进行交互获取任务执行状态。
2 提供一个webui
2.1 overwide
2.2 jobmanager
2.3 taskmanager
2.4 提交作业
2.5 状态监控
2.6 excutionGraph
3 他的JobMaster生成ExecutionGraph
后面我会单独开一个文章来写
4 触发 Checkpoint 操作
后面我会单独开一个文章来写
5 任务调度
后面我会单独开一个文章来写
6 向 yarn 申请资源
后面我会单独开一个文章来写
7 故障恢复
后面我会单独开一个文章来写