Hello, I get the following error whenever a deploy...
# troubleshooting
s
Hello, I get the following error whenever a deploy FlinkDeployment using flink-kuberentes-operator. Job manager pod restarts always for the first time and it comes up for the second time. But the problem with this is, this results in recreating TM pods. Any inputs would be appreciated Thanks.
Copy code
2023-03-05 18:22:06,182 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager at <akka://flink/user/rpc/resourcemanager_0> .
2023-03-05 18:22:06,193 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - Create KubernetesLeaderElector streaming-pipeline-dispatcher-leader with lock identity 5b92b514-7d6a-4203-a50e-c251de97cd74.
2023-03-05 18:22:06,288 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - Starting DefaultLeaderElectionService with KubernetesLeaderElectionDriver{configMapName='streaming-pipeline-dispatcher-leader'}.
2023-03-05 18:22:06,288 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Starting the resource manager.
2023-03-05 18:22:06,293 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - New leader elected a1ce701a-760f-4e87-9e8d-6153f6ee3216 for streaming-pipeline-restserver-leader.
2023-03-05 18:22:06,293 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - New leader elected a1ce701a-760f-4e87-9e8d-6153f6ee3216 for streaming-pipeline-dispatcher-leader.
2023-03-05 18:22:06,388 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='streaming-pipeline-resourcemanager-leader'}.
2023-03-05 18:22:06,491 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='streaming-pipeline-dispatcher-leader'}.
2023-03-05 18:22:07,077 INFO  org.apache.flink.kubernetes.KubernetesResourceManagerDriver  [] - Recovered 0 pods from previous attempts, current attempt id is 1.
2023-03-05 18:22:07,078 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Recovered 0 workers from previous attempt.
2023-03-05 18:22:07,078 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - Create KubernetesLeaderElector streaming-pipeline-resourcemanager-leader with lock identity 5b92b514-7d6a-4203-a50e-c251de97cd74.
2023-03-05 18:22:07,089 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - New leader elected a1ce701a-760f-4e87-9e8d-6153f6ee3216 for streaming-pipeline-resourcemanager-leader.
2023-03-05 18:22:07,117 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - Starting DefaultLeaderElectionService with KubernetesLeaderElectionDriver{configMapName='streaming-pipeline-resourcemanager-leader'}.
2023-03-05 18:22:19,497 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - RECEIVED SIGNAL 15: SIGTERM. Shutting down as requested.
2023-03-05 18:22:19,498 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Shutting KubernetesApplicationClusterEntrypoint down with application status UNKNOWN. Diagnostics Cluster entrypoint has been closed externally..
2023-03-05 18:22:19,499 INFO  org.apache.flink.runtime.blob.BlobServer                     [] - Stopped BLOB server at 0.0.0.0:6124
2023-03-05 18:22:19,499 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Shutting down rest endpoint.
2023-03-05 18:22:19,593 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Shutting down remote daemon.
2023-03-05 18:22:19,593 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Shutting down remote daemon.
2023-03-05 18:22:19,595 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remote daemon shut down; proceeding with flushing remote transports.
2023-03-05 18:22:19,595 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remote daemon shut down; proceeding with flushing remote transports.
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by org.apache.flink.shaded.akka.org.jboss.netty.util.internal.ByteBufferUtil (file:/opt/flink/lib/flink-dist_2.12-1.13.6.jar) to method java.nio.DirectByteBuffer.cleaner()