I am writing to inform you of a recent update we made to our Flink version, upgrading from 1.14 to 1.15, along with a shift from Java 8 to Java 11. Since the update, are seeing below exception
We would appreciate any insights you may have regarding this issue, and any suggestions on how to proceed would be greatly appreciated org.apache.flink.runtime.rpc.exceptions.RecipientUnreachableException org.apache.flink.runtime.rpc.exceptions.RecipientUnreachableException: Could not send message [LocalRpcInvocation(ResourceManagerGateway.registerJobManager(JobMasterId, ResourceID, String, JobID, Time))] from sender [unknown] to recipient [akka.tcp://fl...@xx.xxx.7.6:46017/user/rpc/resourcemanager_2], because the recipient is unreachable. This can either mean that the recipient has been terminated or that the remote RpcService is currently not reachable. Could not send message [LocalRpcInvocation(ResourceManagerGateway.registerJobManager(JobMasterId, ResourceID, String, JobID, Time))] from sender [unknown] to recipient [akka.tcp://fl...@xx.xxx.7.6:46017/user/rpc/resourcemanager_2], because the recipient is unreachable. This can either mean that the recipient has been terminated or that the remote RpcService is currently not reachable. Recipient [Actor[akka://flink/user/rpc/resourcemanager_2#1878283075]] had already been terminated. Message of type [org.apache.flink.runtime.rpc.messages.LocalFencedMessage]. Thanks, Ajinkya
