使用完整的主机名进行 Apache Flink akka 监控



我正在设置一个带有ZooKeeper和3个任务管理器的JobManager HA集群。我在 kubernetes 中这样做,需要 JM 通过完整的主机名(hostname -f不是 hostname(来寻址 TM,因为它们位于有状态的集合中。

目前,TM 似乎将他们的地址报告给 JM 只是 nostname......

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

回答我自己的问题:taskmanager.host是正确的配置。我不确定我做了什么更改使其开始工作,但我的猜测是这与我清除 ZooKeeper 的 flink 数据有关。

相关内容

  • 没有找到相关文章

最新更新