3 on yarn的任务提交过程

1 client向yarn提交相应的Job

2 client上传jar和配置

3 ResourceManager分配Container资源并通知对应的NodeManager启动ApplicationMaster，ApplicationMaster启动后加载flink的jar包和构建环境,启动JobManager

4 ApplicationMaster向ResourceManager申请资源启动taskManager

5 yarn的rm启动taskManager，nodemanager加载flink的jar包和配置环境启动TaskManager

6 TM 向 jobmanager注册slot

7 jobmanager向tm分派任务

推荐阅读更多精彩内容

• Flink任务提交流程（Standalone和Yarn）

  [TOC] 1、任务提交流程（Standalone) 1）App程序通过rest接口提交给Dispatcher（r...

  tracy_668阅读 10,798评论 1赞 4
• flink on yarn 测试环境搭建

  flink on yarn 测试环境搭建 软件版本 hadoop 2.7.3 flink 0.8.0 jdk-8u...

  长名字可以让你朋友更容易记住你阅读 1,542评论 0赞 0
• Flink CookBook-Flink 环境准备

  一、Flink安装 1.1 二进制安装 在官网下载页面下载二进制包，下载的压缩包需要和服务器环境中的Hadoo...

  data之道阅读 504评论 0赞 2
• MapReduce/YARN 架构和任务提交过程

  MapReduce/YARN 工作原理 MRv1 的架构 执行任务的过程： client 向 JobTracker...

  heamon7阅读 3,819评论 0赞 2
• Flink on Yarn模式启动流程分析

  Flink On Yarn 架构 Flink Cluster on Yarn启动过程中，大体可以分为二个阶段1. ...

  fly_xiang阅读 5,021评论 1赞 2