想進(jìn)行query state的時候碰到了這么個問題:

flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:22,669 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:23,660 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:25,700 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:26,659 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:28,710 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:29,659 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:31,725 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:32,657 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:34,732 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:35,672 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:37,740 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:38,656 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1. flink-appleyuchi-standalonesession-2-Desktop.log:2020-09-28 18:10:40,749 WARN org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetriever [] - Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:45297/user/rpc/dispatcher_1.

原因:

集群的各個節(jié)點(diǎn)在局域網(wǎng)中的域名存在大寫字母．

在/etc/hostname中做個映射即可

我的家里的集群是Desktop和Laptop兩個節(jié)點(diǎn)

解決方案：
192.168.0.103?? ?Laptop
192.168.0.102?? ?Desktop

改成:
192.168.0.103?? ?Laptop
192.168.0.103?? ?laptop
192.168.0.102?? ?Desktop
192.168.0.102?? ?desktop

Reference:

[1]使用Flink時遇到的問題（不斷更新中）

總結(jié)

以上是生活随笔為你收集整理的Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:xxxx的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。