微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

与JobManager和JobMaster混淆

如何解决与JobManager和JobMaster混淆

我是Flink的新手。

在Internet上,我总是看到JobManager的概念,但是当我查看Flink源代码(从master分支派生的最新代码

Interface: JobManagerRunner
javadoc: Interface for a runner which executes a {@link JobMaster}.

class: JobMaster
 JobMaster implementation. The job master is responsible for the execution of a single

我想问一下代码中的JobMaster是否正是Internet上JobManager的概念

解决方法

简短的回答:文档中提到的JobManager包括Dispatcher,特定于群集框架的ResourceManager,Blob服务器和一组JobMaster(每个作业一个)。您将在代码中看不到JobManager类。虽然曾经有一个整体式JobManager,但它由FLIP-6重构为一组单独的组件。

更长的答案:

在过去的几年中,术语JobManager已被定义,重新定义和重新定义。

当合并FLIP-6时,在某些文档中进行了重命名-但不是在所有地方,也不在代码中。在这一点上,引入了“ Flink Master”一词来指代JobManager,而代码中称为JobMaster的东西在文档中开始被称为JobManager。

在1.11版本中,我们决定放弃Flink Master术语,并恢复为调用JobManager。自FLIP-6以来我们一直在某些文档中调用JobManager的按作业服务(即调度程序和检查点协调器)的集合(在代码中始终称为JobMaster)现在通常在文档。临时命名方案的一些痕迹可能仍然在此徘徊。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。