I have fixed the issue by increasing the CPU and memory for my JM and TM pods.
Make sure your instance type can accommodate the required resources. On Wed, 19 Jul 2023 at 13:35, Orkhan Dadashov <dadashov.ork...@gmail.com> wrote: > 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_*. >
