我正在设置一个jobmanager ha集群w/zookeeper和3个taskmanager。我在kubernetes做这个,需要jm通过完整的主机名来寻址tms( hostname -f
不是 hostname
)因为它们在一个有状态的集合中。
目前,似乎tms向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
,但没有效果。
如何让tms向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条答案
按热度按时间9jyewag01#
回答我自己的问题:
taskmanager.host
配置是否正确。我不知道我做了什么改变使它开始工作,但我猜这与我清除zookeeper的flink数据有关。