Используйте полное имя хоста для мониторинга Apache Flink akka - PullRequest
Новая
       5

Используйте полное имя хоста для мониторинга Apache Flink akka

0 голосов
/ 12 апреля 2019

Я устанавливаю один кластер JobManager HA с ZooKeeper и 3 TaskManager.Я делаю это в kubernetes и мне нужен JM для адресации ТМ по полному имени хоста (hostname -f, а не hostname), поскольку они находятся в наборе с состоянием.

В настоящее время, похоже, ТМ сообщают о своихобращайтесь к JM как к простому имени ... 

2019-04-12 08:58:32,426 WARN  akka.remote.ReliableDeliverySupervisor                        - Association with remote system [akka.tcp://flink-metrics@flink-taskmanager-1:50011] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink-metrics@flink-taskmanager-1:50011]] Caused by: [flink-taskmanager-1: Name or service not known]
2019-04-12 08:58:32,427 WARN  akka.remote.ReliableDeliverySupervisor                        - Association with remote system [akka.tcp://flink-metrics@flink-taskmanager-0:50011] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink-metrics@flink-taskmanager-0:50011]] Caused by: [flink-taskmanager-0: Name or service not known]
2019-04-12 08:58:32,431 WARN  akka.remote.ReliableDeliverySupervisor                        - Association with remote system [akka.tcp://flink-metrics@flink-taskmanager-2:50011] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink-metrics@flink-taskmanager-2:50011]] Caused by: [flink-taskmanager-2: Name or service not known]

Я просмотрел варианты здесь , в частности taskmanager.host, но это не имело никакого эффекта.

Как я могу заставить TM сообщать JM свой адрес как полное имя хоста или как пользовательское значение? 

root@flink-taskmanager-0:/opt/flink# hostname
flink-taskmanager-0
root@flink-taskmanager-0:/opt/flink# hostname -f
flink-taskmanager-0.fl-taskmanager-headless-service.default.svc.cluster.local

1 Ответ

0 голосов
/ 12 апреля 2019

Чтобы ответить на мой собственный вопрос: taskmanager.host была правильной конфигурацией.Я не знаю наверняка, какое изменение я сделал, чтобы оно начало работать, но я предполагаю, что это связано с тем, что я очищаю данные флеш-памяти ZooKeeper.

...