flink on Yarn的任务提交流程

flink on Yarn提交流程

1.客户端向Dispatcher发起请求

2.Dispatcher向yarn提交job

3.Yarn创建一个Container,启动Application Master

4,Application Master启动一个Flink Resource Manager 和 Job Manager

5.Job Manager根据JobGrap生成的ExecutionGraph以及物理执行计划向flink Resource Manager申请slot

6,如果没用足够的slot,那么flink Resource Manager 向Yarn Resource Manager 申请Container

7.创建Container以后,Container向flink Resource Manager注册

8.注册之后flink Resource Manager 分配slot

9.各Container向Job Manager注册

10,Job Manager向各个Container分配Task.

er向各个Container分配Task.