sdvdxl commented on issue #7263:
URL: https://github.com/apache/seatunnel/issues/7263#issuecomment-2252112594
有的，如下日志
```
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, pipeli
neId=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,
taskG
roupId=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-sm
art_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]-M
ySQL-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-sma
rt_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)],
TaskL
ocation{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 - pi
peline-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.perfo
rmance_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=ActionStat
eKey(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]-MySQ
L-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), A
ctionSubtaskState(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_o
ffline_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=1721386
235797, 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=172138623579
7, 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.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
