В чем отличие Apache Flink (например, v1.8) между менеджером заданий и мастером заданий?
Диспетчер заданий и Мастер заданий, по-видимому, используются в журналах аналогично.
В чем разница между менеджером и мастером?
Спасибо!
JobManager и JobMaster имеют разные роли.
Для JobManager в соответствии с разделом Структуры данных JobManager документации :
Во время выполнения задания JobManager отслеживаетраспределенных задач, решает, когда планировать следующую задачу (или набор задач), и реагирует на завершенные задачи или сбои выполнения. JobManager получает JobGraph, который представляет собой представлениепоток данных, состоящий из операторов (JobVertex) и промежуточных результатов (IntermediateDataSet).Каждый оператор имеет свойства, такие как параллелизм и код, который он выполняет.Кроме того, JobGraph имеет набор подключенных библиотек, которые необходимы для выполнения кода операторов.
Во время выполнения задания JobManager отслеживаетраспределенных задач, решает, когда планировать следующую задачу (или набор задач), и реагирует на завершенные задачи или сбои выполнения.
JobManager получает JobGraph, который представляет собой представлениепоток данных, состоящий из операторов (JobVertex) и промежуточных результатов (IntermediateDataSet).Каждый оператор имеет свойства, такие как параллелизм и код, который он выполняет.Кроме того, JobGraph имеет набор подключенных библиотек, которые необходимы для выполнения кода операторов.
Роль JobMaster более ограничена в соответствии с Javadoc :
JobMaster реализация.Мастер задания отвечает за выполнение одного JobGraph.