Yarn模式的任务提交流程是怎样的?

Flink任务提交后,Client向HDFS上传Flink的Jar包和配置

Client向Yarn ResourceManager提交任务

ResourceManager分配Container资源并通知对应的NodeManager启动ApplicationMaster

ApplicationMaster启动后加载Flink的Jar包和配置构建环境

启动JobManager之后ApplicationMaster向ResourceManager申请资源启动TaskManager

ResourceManager分配Container资源后,由ApplicationMaster通知资源所在节点的NodeManager启动TaskManager

NodeManager加载Flink的Jar包和配置构建环境并启动TaskManager

TaskManager启动后向JobManager发送心跳包,并等待JobManager向其分配任务。

资源下载: