Flink jobmanager报错: ERROR akka.remote.Remoting - Association to [akka.tcp://flink@xxxxx:42895] with UID [-205381938] irrecoverably failed. Quarantining address
我的日志中报错还有段不一样:
java.util.concurrent.TimeoutException: Remote system has been silent for too long. (more than 48.0 hours)
...
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [akka-actor_2.11-2.5.21.jar:2.5.21]
2021-05-23 04:24:24,166 WARN akka.remote.ReliableDeliverySupervisor [] - Association with remote system [akka.tcp://flink@bigdata007:39947] has failed, address is now gated for [50] ms. Reason: [Disassociated]
...
2021-05-23 04:24:28,679 ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler [] - Unhandled exception.
org.apache.flink.runtime.resourcemanager.exceptions.UnknownTaskExecutorException: No TaskExecutor registered under container_e48_1600092789038_34305_01_000006.
不知道有兄弟查出来这个问题的原因是什么没
赞0
踩0