Как назначаются менеджеры заданий Flink при развертывании в режиме приложения? - PullRequest
1 голос
/ 02 августа 2020

От https://flink.apache.org/news/2020/07/14/application-mode.html

Создание кластера для каждого приложения можно рассматривать как создание сеансового кластера, совместно используемого только между заданиями определенного приложения и срываемого после завершения работы приложения.

У каждого задания отдельный JM или общий? Изображение показывает что-то другое, хочу уточнить это. введите описание изображения здесь

Ответы [ 2 ]

1 голос
/ 03 августа 2020

Приложение Flink может состоять из нескольких заданий / частей. При использовании режима приложения Flink развертывает выделенный кластер для приложения. Этот кластер содержит процесс JobManager, который будет использоваться для запуска всех заданий / частей приложения Flink. Следовательно, процесс будет совместно использоваться различными частями приложения.

0 голосов
/ 06 августа 2020

В режиме приложения предполагается, что приложение состоит из нескольких заданий. Каждое задание будет изолированным, имеет отдельный диспетчер заданий и диспетчер задач (что обеспечивает такую ​​же изоляцию ресурсов и гарантии балансировки нагрузки, как и в режиме для каждого задания). Еще одно отличие режима приложения - это метод main () (предполетный), который выполняется в диспетчере заданий вместо клиента.

...