对apache flink akka监视使用完整主机名

8yparm6h  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(378)

我正在设置一个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
9jyewag0

9jyewag01#

回答我自己的问题: taskmanager.host 配置是否正确。我不知道我做了什么改变使它开始工作,但我猜这与我清除zookeeper的flink数据有关。

相关问题