Flink任务提交流程（yarn模式）

 

 

 

 

1. Flink任务提交后，Client向HDFS上传Flink的Jar包和配置，
2. 之后向Yarn ResourceManager提交任务，
3. ResourceManager分配Container资源并通知对应的NodeManager启动ApplicationMaster，
4. ApplicationMaster启动后加载Flink的Jar包和配置构建环境，然后启动JobManager，
5. 之后ApplicationMaster向ResourceManager申请资源启动TaskManager，
6. ResourceManager分配Container资源后，由ApplicationMaster通知资源所在节点的NodeManager启动TaskManager，
7.  NodeManager加载Flink的Jar包和配置构建环境并启动TaskManager，
8. TaskManager启动后向JobManager发送心跳包，并等待JobManager向其分配任务。