flink cdc 遇到akka RemoteRpcInvocation 问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink cdc 遇到akka RemoteRpcInvocation 问题

william
报错日志:
2021-02-16 11:43:49,351 WARN  akka.remote.ReliableDeliverySupervisor                      
[] - Association with remote system [akka.tcp://flink@xxxxxx:45578] has
failed, address is now gated for [50] ms. Reason: [Association failed with
[akka.tcp://flink@xxxxxx:45578]] Caused by: [java.net.ConnectException:
Connection refused: /xxxxxx:45578]

2021-02-16 11:43:50,431 WARN  akka.remote.transport.netty.NettyTransport                  
[] - Remote connection to [null] failed with java.net.ConnectException:
Connection refused: /xxxxxx:45578

2021-02-16 12:48:47,130 ERROR akka.remote.EndpointWriter  [] - dropping
message [class org.apache.flink.runtime.rpc.messages.RemoteRpcInvocation]
for non-local recipient
[Actor[akka.tcp://flink@xxxxxx:45578/user/rpc/taskmanager_0#1283715547]]
arriving at [akka.tcp://flink@xxxxxx:45578] inbound addresses are
[akka.tcp://flink@localhost:6123]



--
Sent from: http://apache-flink.147419.n8.nabble.com/