Как запустить Flink Job Manager и Task Manager на разных узлах? - PullRequest
0 голосов
/ 31 августа 2018

У меня есть продолжительный кластер Flink на Yarn. Это команда для запуска sudo -E flink run -m yarn-cluster -ynm FlinkStreamBootstrap -yn 2 -s $ {SAVEPOINT} -d -c flink.FlinkBootstrap $ {FLINK_LIB} /flink_2.11 - $ { JAR_VERSION} -assembly.jar --jobName "Задание Flink"

Иногда диспетчер задач работает на том же узле, что и менеджер заданий. Иногда отличается. Есть ли способ указать, чтобы запускать их на разных узлах, чтобы начать с?

Спасибо

1 Ответ

0 голосов
/ 31 августа 2018

Flink в настоящее время не поддерживает выражения ограничений размещения для контейнеров пряжи. Flink был разработан, чтобы быть независимым от местоположения, и именно ответственный менеджер кластера должен решить, где распределить ресурсы. Это свойство имеет то преимущество, что не имеет значения, имеет ли кластер Yarn только один очень сложный узел, где он может размещать несколько контейнеров или несколько меньших узлов.

...