开发者社区 问答 正文

Apache Flinkd中启动一个Flink集群向客户端提交作业执行的过程是什么呢?

Apache Flinkd中启动一个Flink集群向客户端提交作业执行的过程是什么呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-08 20:28:29 770 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 当客户端提交作业执行时,首先连接到YARN资源管理器(ResourceManager)以启动一个新的YARN应用程序master进程(Application Master),该进程由一个JobManager线程和一个ResourceManager组成。JobManager从ResourceManager请求所需的slots来运行Flink作业。

    随后,Flink的ResourceManager从YARN的ResourceManager请求容器,并启动TaskManager进程。一旦启动,TaskManagers就会在Flink的ResourceManager上注册它们的slots,Flink的ResourceManager将它们提供给JobManager。

    最后,JobManager将作业的任务提交给TaskManagers执行。

    2021-12-08 21:35:56 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等