Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:xxxx
生活随笔
收集整理的這篇文章主要介紹了
Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:xxxx
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
想進行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.原因:
集群的各個節點在局域網中的域名存在大寫字母.
在/etc/hostname中做個映射即可
我的家里的集群是Desktop和Laptop兩個節點
解決方案:
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時遇到的問題(不斷更新中)
總結
以上是生活随笔為你收集整理的Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@laptop:xxxx的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: HbuildX运行到开发者工具配置
- 下一篇: dnf好友度(dnf好感度满替换大妈)