Hi,
After the previous JobManager fails, K8S start the new JobManager, but the
Leader saved in HA is still the old JobManager address. After the Dispatcher
gets the old JobManager leader, it will try to connect to it.
This error can be ignored, and it will return to normal after waiting for a
p
Hello,
We are running Flink 1.13.6 in Kubernetes with k8s HA, the setup includes 1 JM
and TM. Recently In jobmanager log I started to see:
2022-04-19T00:11:33.102Z Association with remote system
[akka.tcp://flink@10.204.0.126:6123] has failed, address is now gated for [50]
ms. Reason: [Associa
