[Bug] [Seatunnel Zeta] Job status SCHEDULED

[sdvdxl]

[Bug] [Seatunnel Zeta] Job status SCHEDULED

[liunaijie]

can you find any log like this:

pipeline({}) start with savePoint on checkPointId({})

Create CheckpointCoordinator for job({}@{}) with plan({})

Restore job({}@{}) with checkpoint({}), data: {}

[sdvdxl]

有的，如下日志

2024-07-25 13:59:48,030 INFO  [o.a.s.e.s.m.JobMaster         ] [seatunnel-coordinator-service-890] - Init JobMaster for Job sync-smart-ops-sheng-dev-job1 (2000012) 
2024-07-25 13:59:48,030 INFO  [o.a.s.e.s.m.JobMaster         ] [seatunnel-coordinator-service-890] - Job sync-smart-ops-sheng-dev-job1 (2000012) needed jar urls [file:/mnt/sdb1/apache-seatunnel-2.3.5/connectors/connector-starrocks-2.3.5.jar, file:/mnt/sdb1/apache-seatunnel-2.3.5/connectors/connector-cdc-mysql-2.3.5.jar]
2024-07-25 13:59:48,031 INFO  [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-890] - Create classloader for job 2000012 with jars [file:/mnt/sdb1/apache-seatunnel-2.3.5/connectors/connector-starrocks-2.3.5.jar, file:/mnt/sdb1/apache-seatunnel-2.3.5/connectors/connector-cdc-mysql-2.3.5.jar]
2024-07-25 13:59:48,084 INFO  [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-890] - Release classloader for job 2000012 with jars [file:/mnt/sdb1/apache-seatunnel-2.3.5/connectors/connector-starrocks-2.3.5.jar, file:/mnt/sdb1/apache-seatunnel-2.3.5/connectors/connector-cdc-mysql-2.3.5.jar]
2024-07-25 13:59:48,142 INFO  [o.a.s.e.s.c.CheckpointManager ] [seatunnel-coordinator-service-890] - pipeline(1) start with savePoint on checkPointId(44541)
2024-07-25 13:59:48,144 INFO  [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-890] - Create CheckpointCoordinator for job(1@2000012) with plan(CheckpointPlan(pipelineId=1, pipelineSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=360000}, taskID=350000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=240000}, taskID=230000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30007}, taskID=40007, index=7}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30002}, taskID=40002, index=2}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=120000}, taskID=110000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=390000}, taskID=380000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30003}, taskID=40003, index=3}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=330000}, taskID=320000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=210000}, taskID=200000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30005}, taskID=40005, index=5}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=90000}, taskID=80000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30006}, taskID=40006, index=6}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=300000}, taskID=290000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30001}, taskID=40001, index=1}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=180000}, taskID=170000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=450000}, taskID=440000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=60000}, taskID=50000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30008}, taskID=40008, index=8}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=270000}, taskID=260000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30009}, taskID=40009, index=9}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30004}, taskID=40004, index=4}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=150000}, taskID=140000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=420000}, taskID=410000, index=0}], startingSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], pipelineActions={ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.plan_device])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_record_day])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_device_fluency_result])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.plan_info])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.check_item])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_last_task_record])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_device_state_result])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_result])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]])=10, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_info])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC])=10, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_record])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_storage_result])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.performance_rule_config])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.performance_report])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_pic])=1}, subtaskActions={TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=360000}, taskID=350000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_info -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_info]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_info]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30007}, taskID=40007, index=7}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 7), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 7)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=120000}, taskID=110000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_device_state_result]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_device_state_result -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_device_state_result]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=390000}, taskID=380000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_record -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_record]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_record]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30003}, taskID=40003, index=3}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 3), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 3)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=330000}, taskID=320000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_record_day]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_record_day -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_record_day]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=90000}, taskID=80000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.plan_info]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.plan_info -> pipeline-1 [Sink[0]-StarRocks-smart_ops.plan_info]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=300000}, taskID=290000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_last_task_record]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.device_last_task_record -> pipeline-1 [Sink[0]-StarRocks-smart_ops.device_last_task_record]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30001}, taskID=40001, index=1}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 1), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 1)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=450000}, taskID=440000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_device_fluency_result]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_device_fluency_result -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_device_fluency_result]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=60000}, taskID=50000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.plan_device]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.plan_device -> pipeline-1 [Sink[0]-StarRocks-smart_ops.plan_device]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30008}, taskID=40008, index=8}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 8), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 8)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30004}, taskID=40004, index=4}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 4), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 4)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=150000}, taskID=140000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_result]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_video_result -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_result]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=240000}, taskID=230000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.performance_rule_config -> pipeline-1 [Sink[0]-StarRocks-smart_ops.performance_rule_config]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.performance_rule_config]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30002}, taskID=40002, index=2}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 2), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 2)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=210000}, taskID=200000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_video_storage_result -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_storage_result]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_storage_result]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), -1)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30005}, taskID=40005, index=5}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 5), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 5)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30006}, taskID=40006, index=6}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 6), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 6)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=180000}, taskID=170000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.check_item]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.check_item -> pipeline-1 [Sink[0]-StarRocks-smart_ops.check_item]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=270000}, taskID=260000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.performance_report -> pipeline-1 [Sink[0]-StarRocks-smart_ops.performance_report]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.performance_report]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=30009}, taskID=40009, index=9}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 9), (ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]]), 9)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=2000012, pipelineId=1, taskGroupId=420000}, taskID=410000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Shuffle [Source[0]-MySQL-CDC]] -> smart_ops.task_video_pic -> pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_pic]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.task_video_pic]), 0)]}))
2024-07-25 13:59:48,145 INFO  [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-890] - Restore job(1@2000012) with checkpoint(44541), data: CompletedCheckpoint(jobId=2000012, pipelineId=1, checkpointId=44541, triggerTimestamp=1721386235795, checkpointType=CHECKPOINT_TYPE, completedTimestamp=1721386235798, taskStates={ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]])=ActionState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), subtaskStates=[ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=0), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=1), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=2), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=3), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=4), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=5), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=6), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=7), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=8), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-FilterRowKind]]), index=9)], coordinatorState=null, parallelism=10), ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC])=ActionState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), subtaskStates=[ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=0), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=1), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=2), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=3), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=4), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=5), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=6), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=7), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=8), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=9)], coordinatorState=ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), index=-1), parallelism=10), ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record])=ActionState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), subtaskStates=[ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=0), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=1), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=2), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=3), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=4), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=5), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=6), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=7), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=8), ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-smart_ops.device_offline_record]), index=9)], coordinatorState=null, parallelism=10)}, taskStatistics={2=TaskStatistics(jobVertexId=2, subtaskStats=[SubtaskStatistics(subtaskIndex=0, ackTimestamp=1721386235797, stateSize=1, subtaskStatus=RUNNING)], subtaskCompleted=[false], numAcknowledgedSubtasks=1, latestAckedSubtaskStatistics=null), 4=TaskStatistics(jobVertexId=4, subtaskStats=[SubtaskStatistics(subtaskIndex=0, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=1, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=2, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=3, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=4, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=5, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=6, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=7, ackTimestamp=1721386235797, stateSize=1, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=8, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=9, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING)], subtaskCompleted=[false, false, false, false, false, false, false, false, false, false], numAcknowledgedSubtasks=10, latestAckedSubtaskStatistics=null), 5=TaskStatistics(jobVertexId=5, subtaskStats=[SubtaskStatistics(subtaskIndex=0, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=1, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=2, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=3, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=4, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=5, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=6, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=7, ackTimestamp=1721386235798, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=8, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING), SubtaskStatistics(subtaskIndex=9, ackTimestamp=1721386235797, stateSize=0, subtaskStatus=RUNNING)], subtaskCompleted=[false, false, false, false, false, false, false, false, false, false], numAcknowledgedSubtasks=10, latestAckedSubtaskStatistics=null)}, isRestored=true)
2024-07-25 13:59:48,145 INFO  [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-890] - Turn checkpoint_state_2000012_1 state from null to RUNNING
2024-07-25 13:59:48,146 INFO  [o.a.s.e.s.d.p.PhysicalVertex  ] [seatunnel-coordinator-service-890] - The task Job sync-smart-ops-sheng-dev-job1 (2000012), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/10)] is in state CREATED when init state future
2024-07-25 13:59:48,148 INFO  [o.a.s.e.s.d.p.PhysicalPlan    ] [seatunnel-coordinator-service-890] - Job sync-smart-ops-sheng-dev-job1 (2000012) state process is start
2024-07-25 13:59:48,148 INFO  [o.a.s.e.s.d.p.PhysicalPlan    ] [seatunnel-coordinator-service-890] - Job sync-smart-ops-sheng-dev-job1 (2000012) turned from state CREATED to SCHEDULED.
2024-07-25 13:59:48,148 INFO  [o.a.s.e.s.d.p.SubPlan         ] [seatunnel-coordinator-service-890] - Job sync-smart-ops-sheng-dev-job1 (2000012), Pipeline: [(1/1)] state process is start
2024-07-25 13:59:48,149 INFO  [o.a.s.e.s.d.p.SubPlan         ] [seatunnel-coordinator-service-890] - Job sync-smart-ops-sheng-dev-job1 (2000012), Pipeline: [(1/1)] turned from state CREATED to SCHEDULED.