You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Ajinkya Pathrudkar <aj...@gmail.com> on 2023/03/22 02:57:00 UTC
org.apache.flink.runtime.rpc.exceptions.RecipientUnreachableException
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://flink@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://flink@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
Re: org.apache.flink.runtime.rpc.exceptions.RecipientUnreachableException
Posted by Shammon FY <zj...@gmail.com>.
Hi Ajinkya
It seems that the JobMaster is not started successfully. If possible, you
can provide more information to help analyze the problem.
Best,
Shammon FY
On Wed, Mar 22, 2023 at 10:57 AM Ajinkya Pathrudkar <
ajinkya.pathrudkar11@gmail.com> wrote:
>
> 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://flink@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://flink@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
>