Automati c возобновление работы при перезапуске кластера flink - PullRequest
0 голосов
/ 29 января 2020

Я выполняю задания в автономном кластере flink с одним диспетчером заданий, работающим в контейнере docker. Всякий раз, когда кластер выходит из строя и перезапускается, я должен снова отправить задания вручную для их запуска. Есть ли способ заставить flink возобновить работу автоматически после повторного запуска кластера?

1 Ответ

1 голос
/ 30 января 2020

Если задание завершается сбоем из-за исключения, диспетчер заданий автоматически перезапускает его, если (1) у вас включена контрольная точка (по умолчанию она отключена, поскольку требует некоторой настройки), и ( 2) вы не установили стратегию перезапуска , которая предотвращает перезапуски (стратегия перезапуска по умолчанию подходит). Если диспетчер задач в автономном кластере полностью выходит из строя, вам нужно запустить еще один.

Чтобы настроить аварийное переключение диспетчера заданий, см. Документы о высокой доступности для автономных кластеров .

...