You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Orkhan Dadashov <da...@gmail.com> on 2023/07/19 17:14:42 UTC
TM fails to register with JM while trying to run basic.yaml example with Flink K8S operator
Hi Flink users,
I'm following up on this guide to try the Flink K8S operator (1.5.0 version
):
https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.5/docs/try-flink-kubernetes-operator/quick-start/
When I try to deploy a basic example, JM and TM start, but TM fails to
register with JM :
kubectl create -f
https://raw.githubusercontent.com/apache/flink-kubernetes-operator/release-1.5/examples/basic.yaml
Wanted to check if anyone has faced a similar issue or how to resolve this
issue.
Thank you.
Here is the exception stack trace:
2023-07-19 06:12:23,448 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could
not resolve ResourceManager address
akka.tcp://flink@basic-example.default:6123/user/rpc/resourcemanager_*,
retrying in 10000 ms: Could not connect to rpc endpoint under address
akka.tcp://flink@basic-example.default:6123/user/rpc/resourcemanager_*.
2023-07-19 06:12:33,448 INFO akka.remote.transport.ProtocolStateActor
[] - No response from remote for outbound association.
Associate timed out after [20000 ms].
2023-07-19 06:12:33,448 WARN akka.remote.ReliableDeliverySupervisor
[] - Association with remote system
[akka.tcp://flink@basic-example.default:6123] has failed, address is now
gated for [50] ms. Reason: [Association failed with
[akka.tcp://flink@basic-example.default:6123]] Caused by: [No response from
remote for outbound association. Associate timed out after [20000 ms].]
2023-07-19 06:12:33,460 WARN akka.remote.transport.netty.NettyTransport
[] - Remote connection to [null] failed with
org.jboss.netty.channel.ConnectTimeoutException: connection timed out:
basic-example.default/10.0.3.192:6123
2023-07-19 06:12:33,469 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could
not resolve ResourceManager address
akka.tcp://flink@basic-example.default:6123/user/rpc/resourcemanager_*,
retrying in 10000 ms: Could not connect to rpc endpoint under address
akka.tcp://flink@basic-example.default:6123/user/rpc/resourcemanager_*.
2023-07-19 06:12:53,508 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could
not resolve ResourceManager address
akka.tcp://flink@basic-example.default:6123/user/rpc/resourcemanager_*,
retrying in 10000 ms: Could not connect to rpc endpoint under address
akka.tcp://flink@basic-example.default:6123/user/rpc/resourcemanager_*.