【Flink运行时架构】作业提交流程

时间:2025-04-17 10:16:35
  • 客户端将作业提交给YARN的RM;
  • YARN的RM启动Flink JobManager,并将作业提交给JobMaster;
  • JobMaster向Flink内置的RM请求slots;
  • Flink内置的RM向YARN RM请求容器;
  • YARN 启动带有TaskManager的容器;
  • TaskManager启动之后,向Flink的RM注册自己的可用slots;
  • Flink的RM通知TaskManager为作业提供slots;
  • TaskManager连接到对应的JobMaster,并提供slots;
  • JobMaster将需要执行的作业分发给TaskManager执行。