Pastein: k logs test-new-op-cluster-7647675d9-jztct -c flink-main-container --since=10m | grep -iE 'leader|leadership|recover|jobmaster|dispatcher|error|exception' 2026-10-19 22:27:17,309 INFO org.apache.fli

Загрузка данных
k logs test-new-op-cluster-7647675d9-jztct -c flink-main-container --since=10m | grep -iE 'leader|leadership|recover|jobmaster|dispatcher|error|exception'
2026-10-19 22:27:17,309 INFO  org.apache.flink.runtime.dispatcher.FileExecutionGraphInfoStore [] - Initializing FileExecutionGraphInfoStore: Storage directory /tmp/executionGraphStore-cf95af8b-bf2a-4aad-a6b9-4a3f0fb2a597, expiration time 3600000, maximum cache size 52428800 bytes.
2026-10-19 22:27:17,358 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Upload directory /tmp/flink-web-00174b36-5d0b-4eac-ba07-25714cc3ab1d/flink-web-upload does not exist. 
2026-10-19 22:27:17,359 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Created directory /tmp/flink-web-00174b36-5d0b-4eac-ba07-25714cc3ab1d/flink-web-upload for file uploads.
2026-10-19 22:27:17,360 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Starting rest endpoint.
2026-10-19 22:27:17,541 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Rest endpoint listening at 10.42.16.11:8081
2026-10-19 22:27:17,547 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 (366b3327-eb9f-4926-9e72-6c81498f005e).
2026-10-19 22:27:17,551 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 (366b3327-eb9f-4926-9e72-6c81498f005e).
2026-10-19 22:27:17,551 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 22:27:17,551 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 22:27:17,552 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Web frontend listening at http://10.42.16.11:8081.
2026-10-19 22:27:17,722 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 22:27:17,722 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 22:27:17,725 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 22:27:17,725 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 22:27:17,829 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 22:27:17,930 INFO  org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector [] - New leader elected 366b3327-eb9f-4926-9e72-6c81498f005e for test-new-op-cluster-cluster-config-map.
2026-10-19 22:27:17,934 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - http://10.42.16.11:8081 was granted leadership with leaderSessionID=35a52100-9668-4fa1-a123-828b21656d47
2026-10-19 22:27:17,935 INFO  org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Resource manager service is granted leadership with session id 35a52100-9668-4fa1-a123-828b21656d47.
2026-10-19 22:27:17,936 INFO  org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id 35a52100-9668-4fa1-a123-828b21656d47. Creating new DispatcherLeaderProcess.
2026-10-19 22:27:18,030 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess.
2026-10-19 22:27:19,519 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs that are not finished, yet.
2026-10-19 22:27:19,714 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Trying to recover job with job id 75d2f7ba5307ca9ada789cf13aac6821.
2026-10-19 22:27:20,724 INFO  org.apache.flink.runtime.jobmanager.DefaultJobGraphStore     [] - Recovered JobGraph(jobId: 75d2f7ba5307ca9ada789cf13aac6821).
2026-10-19 22:27:20,725 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 1 persisted job graphs.
2026-10-19 22:27:20,821 INFO  org.apache.flink.runtime.rpc.pekko.PekkoRpcService           [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at pekko://flink/user/rpc/dispatcher_1 .
2026-10-19 22:27:21,920 INFO  org.apache.flink.kubernetes.KubernetesResourceManagerDriver  [] - Recovered 1 pods from previous attempts, current attempt id is 2.
2026-10-19 22:27:22,003 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Recovered 1 workers from previous attempt.
2026-10-19 22:27:22,005 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Worker test-new-op-cluster-taskmanager-1-1 recovered from previous attempt.
2026-10-19 22:27:22,825 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Pending recovery taskmanagers 1 -> 0. Resource manager is ready to serve.
2026-10-19 22:27:22,825 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Recovered worker test-new-op-cluster-taskmanager-1-1 with resource spec WorkerResourceSpec {cpuCores=6.0, taskHeapSize=3.870gb (4155380836 bytes), taskOffHeapSize=0 bytes, networkMemSize=527.360mb (552977046 bytes), managedMemSize=527.360mb (552977046 bytes), numSlots=7} registered
2026-10-19 22:27:24,735 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 22:27:24,812 INFO  org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner [] - JobMasterServiceLeadershipRunner for job 75d2f7ba5307ca9ada789cf13aac6821 was granted leadership with leader id 35a52100-9668-4fa1-a123-828b21656d47. Creating new JobMasterServiceProcess.
2026-10-19 22:27:24,832 INFO  org.apache.flink.runtime.rpc.pekko.PekkoRpcService           [] - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at pekko://flink/user/rpc/jobmanager_2 .
2026-10-19 22:27:24,840 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Initializing job 'huawei-dpi-ros-test' (75d2f7ba5307ca9ada789cf13aac6821).
2026-10-19 22:27:24,919 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Using restart back off time strategy ExponentialDelayRestartBackoffTimeStrategy(initialBackoffMS=1000, maxBackoffMS=60000, backoffMultiplier=1.5, resetBackoffThresholdMS=3600000, jitterFactor=0.1, attemptsBeforeResetBackoff=2147483647, currentRestartAttempt=0, nextRestartTimestamp=-2147483648) for huawei-dpi-ros-test (75d2f7ba5307ca9ada789cf13aac6821).
2026-10-19 22:27:24,949 INFO  org.apache.flink.runtime.checkpoint.DefaultCompletedCheckpointStoreUtils [] - Recovering checkpoints from KubernetesStateHandleStore{configMapName='test-new-op-cluster-75d2f7ba5307ca9ada789cf13aac6821-config-map'}.
2026-10-19 22:27:25,405 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 22:27:25,405 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Starting execution of job 'huawei-dpi-ros-test' (75d2f7ba5307ca9ada789cf13aac6821) under job master id a123828b21656d4735a5210096684fa1.
2026-10-19 22:27:25,414 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Connecting to ResourceManager pekko.tcp://flink@10.42.16.11:6123/user/rpc/resourcemanager_0(a123828b21656d4735a5210096684fa1)
2026-10-19 22:27:25,420 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Resolved ResourceManager address, beginning registration
2026-10-19 22:27:25,426 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with KubernetesLeaderRetrievalDriver{configMapName='test-new-op-cluster-cluster-config-map'}.
2026-10-19 22:27:25,516 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - JobManager successfully registered at ResourceManager, leader id: a123828b21656d4735a5210096684fa1.
Больше возможностей при регистрации:
