开发者社区 问答 正文

Flink任务提交流程是什么?

Flink任务提交流程是什么?

展开
收起
芯在这 2021-12-09 18:45:12 538 分享 版权
1 条回答
写回答
取消 提交回答
  • Flink任务提交后,Client向HDFS上传Flink的jar包和配置,之后向Yarn ResourceManager提交任务,ResourceManager分配Container资源并通知对应的NodeManager启动 ApplicationMaster,ApplicationMaster启动后加载Flink的jar包和配置构建环境,然后启动JobManager;之后Application Master向ResourceManager申请资源启动TaskManager ,ResourceManager分配Container资源后,由ApplicationMaster通知资源所在的节点的NodeManager启动TaskManager,NodeManager加载Flink的Jar包和配置构建环境并启动TaskManager,TaskManager启动向JobManager发送心跳,并等待JobManager向其分配任务。

    2021-12-09 18:45:33
    赞同 展开评论