---

k logs test-new-op-cluster-7647675d9-r2gtp -c flink-main-container | grep -iE 'leader|leadership|grant|revoke'
2026-10-19 14:33:54,065 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - Create KubernetesLeaderElector on lock ConfigMapLock: bdo-tst-flink-test-new-op - test-new-op-cluster-cluster-config-map (5e0bbe91-eae3-4480-b325-ade08598e532).
2026-10-19 14:33:54,069 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - Triggered leader election on lock ConfigMapLock: bdo-tst-flink-test-new-op - test-new-op-cluster-cluster-config-map (5e0bbe91-eae3-4480-b325-ade08598e532).
2026-10-19 14:33:54,070 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - A connection to the HA backend was established through LeaderElectionDriver KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:54,070 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - LeaderContender has been registered under component 'restserver' for KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:54,217 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - LeaderContender has been registered under component 'dispatcher' for KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:54,217 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - LeaderContender has been registered under component 'resourcemanager' for KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:54,219 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:54,219 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:54,223 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - New leader elected ab5a5b17-2bb7-4f7e-9d99-002c862199a9 for test-new-op-cluster-cluster-config-map.
➜  flink git:(feature/BDOPS-901) k logs test-new-op-cluster-7647675d9-vqkqs -c flink-main-container | grep -iE 'leader|leadership|grant|revoke'
2026-10-19 14:33:52,823 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - Create KubernetesLeaderElector on lock ConfigMapLock: bdo-tst-flink-test-new-op - test-new-op-cluster-cluster-config-map (ab5a5b17-2bb7-4f7e-9d99-002c862199a9).
2026-10-19 14:33:52,881 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - Triggered leader election on lock ConfigMapLock: bdo-tst-flink-test-new-op - test-new-op-cluster-cluster-config-map (ab5a5b17-2bb7-4f7e-9d99-002c862199a9).
2026-10-19 14:33:52,881 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - A connection to the HA backend was established through LeaderElectionDriver KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:52,881 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - LeaderContender has been registered under component 'restserver' for KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:52,982 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - LeaderContender has been registered under component 'dispatcher' for KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:52,982 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - LeaderContender has been registered under component 'resourcemanager' for KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:52,984 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:52,984 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:33:52,995 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - New leader elected 860ab406-2742-4983-9824-f7ada8f69f57 for test-new-op-cluster-cluster-config-map.
2026-10-19 14:33:53,017 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - New leader elected ab5a5b17-2bb7-4f7e-9d99-002c862199a9 for test-new-op-cluster-cluster-config-map.
2026-10-19 14:33:53,020 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - http://10.42.20.90:8081 was granted leadership with leaderSessionID=56957f90-86f0-4ea9-9f0f-8d7a8fc9db51
2026-10-19 14:33:53,020 INFO  org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Resource manager service is granted leadership with session id 56957f90-86f0-4ea9-9f0f-8d7a8fc9db51.
2026-10-19 14:33:53,081 INFO  org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id 56957f90-86f0-4ea9-9f0f-8d7a8fc9db51. Creating new DispatcherLeaderProcess.
2026-10-19 14:33:53,093 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess.
2026-10-19 14:33:53,892 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs that are not finished, yet.
2026-10-19 14:33:53,983 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs.
2026-10-19 14:34:28,283 INFO  org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - LeaderContender has been registered under component 'job-75d2f7ba5307ca9ada789cf13aac6821' for KubernetesLeaderElectionDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:34:28,292 INFO  org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner [] - JobMasterServiceLeadershipRunner for job 75d2f7ba5307ca9ada789cf13aac6821 was granted leadership with leader id 56957f90-86f0-4ea9-9f0f-8d7a8fc9db51. Creating new JobMasterServiceProcess.
2026-10-19 14:34:28,520 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:34:28,590 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 14:34:28,600 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - JobManager successfully registered at ResourceManager, leader id: 9f0f8d7a8fc9db5156957f9086f04ea9.