Re: flink on yarn , JobManager和ApplicationMaster的关系

2021-02-02 文章 lp
谢谢! 我摘录的是flink1.11.2版本文档最后那部分:Background / Internals,介绍flink 如何在yarn上运行的 的内容:https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/yarn_setup.html 。感觉版本比较新了,应该没有问题吧,也是我们生产上在用的版本。1.12版本中没有找到相关内容。 仔细看了下文档,可能是我对flink on yarn的理解不太清楚,还是有几个问题请教下: ①flink on yarn模式下,jobmanager 和 app

Re: flink on yarn , JobManager和ApplicationMaster的关系

2021-02-02 文章 Xintong Song
你之前的理解是正确的。Yarn 的 AM 就是 Flink 的 JM。 你看到的文档描述是有问题的。我查了一下 git history,你所摘录的内容 2014 年撰写的,描述的应该是项目初期的 on yarn 部署方式,早已经过时了。这部分内容在最新的 1.12 版本文档中已经被移除了。 Thank you~ Xintong Song On Tue, Feb 2, 2021 at 6:43 PM lp <973182...@qq.com> wrote: > 或者说,我知道,对于MapReduce任务,ApplicationMaster的实现是MRAppMaster,那flin

Re: flink on yarn , JobManager和ApplicationMaster的关系

2021-02-02 文章 lp
或者说,我知道,对于MapReduce任务,ApplicationMaster的实现是MRAppMaster,那flink on yarn ,ApplicationMaster对应的实现是啥? -- Sent from: http://apache-flink.147419.n8.nabble.com/

flink on yarn , JobManager和ApplicationMaster的关系

2021-02-02 文章 lp
flink on yarn中,yarn的applicationMaster和flink JobManager的关系是啥,我对yarn不是很熟悉,之前的理解是 JobManager就是yarn中的applicationMaster的角色。但我在官网中看到如下摘录:...Once that has finished, the ApplicationMaster (AM) is started.The JobManager and AM are running in the same container. Once they successfully started, the AM knows t