报错日志:
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/