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_*.
