与JobManager和JobMaster混淆

Question

我是Flink的新手。

在互联网上，我总是看到概念分支，但当我查看JobManager的源代码时(最新的代码来自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是否是互联网上JobManager的概念

Answer 1

简而言之:文档中提到的JobManager包括Dispatcher、特定于集群框架的ResourceManager、Blob Server和一组JobMasters (每个作业一个)。您在代码中看不到JobManager类；虽然曾经有一个单一的JobManager，但是通过FLIP-6将其重构为一组独立的组件。

更长的答案：

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

当FLIP-6被合并时，在一些文档中进行了重命名--但不是在所有地方，也不是在代码中。在这一点上，术语"Flink Master“被引入来指代曾经的JobManager，并且代码所指的JobMaster开始在文档中被称为JobManager。

随着1.11版本的发布，我们决定放弃Flink Master术语，并重新将其称为JobManager。我们从FLIP-6开始在一些文档中调用JobManager (并且在代码中总是调用JobMaster )的每个作业服务的集合(即调度器和检查点协调器)现在通常在文档中保持未命名。临时命名方案的一些痕迹可能仍在各处挥之不去。