NYC's Blog - Flink快速了解（3）——4种Graph 的评论 本文介绍Flink任务流转过程中涉及的图，知道这些可以更好的了解Flink的运行流程。如上图，Flink中有4种图：StreamGraph、JobGraph、ExecutionGraph、Phy... 2021-12-30T16:34:06+08:00 Typecho http://niyanchun.com/feed/atom/flink-quick-learning-graph.html <![CDATA[王桑~]]> http://niyanchun.com/flink-quick-learning-graph.html/comment-page-1#comment-706 2021-12-30T16:34:06+08:00 2021-12-30T16:34:06+08:00 王桑~ 自问自答：

Job的提交过程：

  • 下载应用所需的依赖
  • 执行main()方法提取 job graph
  • 将依赖和 job graph 传输到集群
  • 有可能需要等待结果
  1. 博主的4种Graph的生产流程适用于per-job、yarn session这样的部署方式
  2. flink 1.11后引入了 application mode, 执行main（）方法移动到JobMaster中进行（？瞎猜的），而生成JobGraph也在JobMaster中生成了
]]> <![CDATA[王桑~]]> http://niyanchun.com/flink-quick-learning-graph.html/comment-page-1#comment-705 2021-12-30T16:26:29+08:00 2021-12-30T16:26:29+08:00 王桑~ 您好，请教个问题

  1. flink 1.11后，引入了application mode，这个模是在集群侧执行main方法的
    那么是否，StreamGraph和JobGraph的生成，也是由Client端-->后移到了集群端生成？
  2. application mode 的main方法不在client端执行了，那么在集群哪个模块执行？job master? dispatcher?
]]>