I am running Flink 1.3.2 in my local docker environment.

I see this error, not sure how to find the root cause.
I am confused by this error message, why JM is trying to connect to JM from
one random port to the RPC port: 6123?

====
2018-01-08 05:38:03,294 ERROR akka.remote.EndpointWriter - AssociationError
[akka.tcp://flink@fps-flink-jobmanager:6123] <-
[akka.tcp://flink@fps-flink-jobmanager:45652]: Error [Shut down address:
akka.tcp://flink@fps-flink-jobmanager:45652] [
akka.remote.ShutDownAssociation: Shut down address:
akka.tcp://flink@fps-flink-jobmanager:45652
Caused by: akka.remote.transport.Transport$InvalidAssociationException: The
remote system terminated the association because it is shutting down.
]
====

Here you can find the full log
https://gist.github.com/zenhao/c8d13cce8601e321dd706a2ac53f5032

Reply via email to