[
https://issues.apache.org/jira/browse/FLINK-39788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vladislav Keda updated FLINK-39788:
-----------------------------------
Description:
Flink Session Kubernetes deployment fails when namespace starts from digit, for
example `1234-ns`
{code:java}
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.rpc.exceptions.RpcConnectionException: Could not
connect to rpc endpoint under address
pekko.tcp://[email protected]:6123/user/rpc/dispatcher_*.
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcService.lambda$resolveActorAddress$10(PekkoRpcService.java:556)
~[?:?]
at
scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:67)
~[?:?]
... 5 more
Caused by: org.apache.flink.runtime.rpc.exceptions.RpcConnectionException:
Could not connect to rpc endpoint under address
pekko.tcp://[email protected]:6123/user/rpc/dispatcher_*.
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcService.lambda$resolveActorAddress$10(PekkoRpcService.java:556)
~[?:?]
at
scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:67)
~[?:?]
... 5 more
Caused by: org.apache.pekko.actor.ActorNotFound: Actor not found for:
ActorSelection[Anchor(pekko://flink/deadLetters), Path(/)]{code}
was:
Exception for Flink Session Kubernetes deployment when namespace starts from
digit, for example `1234-ns`
{code:java}
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.rpc.exceptions.RpcConnectionException: Could not
connect to rpc endpoint under address
pekko.tcp://[email protected]:6123/user/rpc/dispatcher_*.
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcService.lambda$resolveActorAddress$10(PekkoRpcService.java:556)
~[?:?]
at
scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:67)
~[?:?]
... 5 more
Caused by: org.apache.flink.runtime.rpc.exceptions.RpcConnectionException:
Could not connect to rpc endpoint under address
pekko.tcp://[email protected]:6123/user/rpc/dispatcher_*.
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcService.lambda$resolveActorAddress$10(PekkoRpcService.java:556)
~[?:?]
at
scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:67)
~[?:?]
... 5 more
Caused by: org.apache.pekko.actor.ActorNotFound: Actor not found for:
ActorSelection[Anchor(pekko://flink/deadLetters), Path(/)]{code}
> Pekko error "Actor not found" when Kubernetes namespace starts from digit
> --------------------------------------------------------------------------
>
> Key: FLINK-39788
> URL: https://issues.apache.org/jira/browse/FLINK-39788
> Project: Flink
> Issue Type: Bug
> Components: Deployment / Kubernetes, Runtime / RPC
> Affects Versions: 1.20.3
> Reporter: Vladislav Keda
> Priority: Major
>
> Flink Session Kubernetes deployment fails when namespace starts from digit,
> for example `1234-ns`
> {code:java}
> Caused by: java.util.concurrent.CompletionException:
> org.apache.flink.runtime.rpc.exceptions.RpcConnectionException: Could not
> connect to rpc endpoint under address
> pekko.tcp://[email protected]:6123/user/rpc/dispatcher_*.
> at
> org.apache.flink.runtime.rpc.pekko.PekkoRpcService.lambda$resolveActorAddress$10(PekkoRpcService.java:556)
> ~[?:?]
> at
> scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:67)
> ~[?:?]
> ... 5 more
> Caused by: org.apache.flink.runtime.rpc.exceptions.RpcConnectionException:
> Could not connect to rpc endpoint under address
> pekko.tcp://[email protected]:6123/user/rpc/dispatcher_*.
> at
> org.apache.flink.runtime.rpc.pekko.PekkoRpcService.lambda$resolveActorAddress$10(PekkoRpcService.java:556)
> ~[?:?]
> at
> scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:67)
> ~[?:?]
> ... 5 more
> Caused by: org.apache.pekko.actor.ActorNotFound: Actor not found for:
> ActorSelection[Anchor(pekko://flink/deadLetters), Path(/)]{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
