**

flink任务提交的流程

**
flink任务提交的流程

flink提交任务后,Client向HDFS上传Flink的jar包和配置,之后向Yarn ResourceManager提交任务,ResourceManager分配Container资源并通知对应的NodeManager启动相应的ApplicationMaster,ApplicationMaster启动后加载Flink的Jar包和配置构建环境,然后启动JobManager,之后ApplicationMaster通知资源所在节点的NodeManager启动TaskManager,NodeManager加载Flink的jar包和配置构建并启动TaskManager,TaskManager启动后向JobManager发送心跳包,并等待JobManager向其分配任务。

相关文章:

  • 2022-12-23
  • 2021-07-15
  • 2022-12-23
  • 2021-01-19
  • 2022-12-23
  • 2021-09-24
  • 2021-05-24
猜你喜欢
  • 2021-09-17
  • 2021-07-10
  • 2021-04-21
  • 2021-09-18
  • 2021-09-01
  • 2022-01-01
  • 2021-11-04
相关资源
相似解决方案