Flink 1.7.2: диспетчер задач не может подключиться к диспетчеру заданий - PullRequest
Новая
       17

Flink 1.7.2: диспетчер задач не может подключиться к диспетчеру заданий

1 голос
/ 14 марта 2019

Я пытаюсь обновить наш кластер Flink с 1.4.2 до 1.7.2

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

2019-03-14 10:34:41,551 WARN  akka.remote.ReliableDeliverySupervisor                        
- Association with remote system [akka.tcp://flink@cluster:22671] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@cluster:22671]] Caused by: [cluster: Name or service not known]

Теперь, это работает правильно, если я добавлю следующую строку в файл /etc/hosts. 

x.x.x.x job-manager-address.com cluster

Почему Flink 1.7.2 подключается к JM, используя cluster в адресе? Flink 1.4.2 имел обыкновение иметь адрес менеджера работы вместо слова cluster.

1 Ответ

1 голос
/ 15 марта 2019

Сценарий jobmanager.sh вызывался со вторым аргументом, называемым cluster. 

${Flink_HOME}/bin/jobmanager.sh start cluster

До версии 1.5 сценарий ожидал режим выполнения (локальный или кластерный), но это уже не так. Вызов сценария без второго аргумента решил эту проблему. 

${Flink_HOME}/bin/jobmanager.sh start
...