W-dragan commented on issue #4915:
URL: https://github.com/apache/seatunnel/issues/4915#issuecomment-1975500594
2024-03-04 09:24:23,868 INFO
org.apache.seatunnel.engine.server.master.JobMaster - in batch mode, the
'checkpoint.interval' configuration of env is missing, so checkpoint will be
disabled
392
2024-03-04 09:24:23,868 INFO
org.apache.seatunnel.engine.server.master.JobMaster - Init JobMaster for Job
SeaTunnel_Job (816843488111886338)
393
2024-03-04 09:24:23,868 INFO
org.apache.seatunnel.engine.server.master.JobMaster - Job SeaTunnel_Job
(816843488111886338) needed jar urls
[file:/opt/seatunnel/connectors/connector-jdbc-2.3.4-geega1.0.0-SNAPSHOT.jar]
394
2024-03-04 09:24:23,870 INFO
org.apache.seatunnel.engine.common.loader.ClassLoaderUtil - recycle classloader
org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader@248f5588
395
2024-03-04 09:24:23,884 INFO
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Create
CheckpointCoordinator for job(1@816843488111886338) with
plan(CheckpointPlan(pipelineId=1,
pipelineSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=816843488111886338,
pipelineId=1, taskGroupId=30000}, taskID=40000, index=0},
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=816843488111886338,
pipelineId=1, taskGroupId=30000}, taskID=50000, index=0},
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=816843488111886338,
pipelineId=1, taskGroupId=1}, taskID=20000, index=0}],
startingSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=816843488111886338,
pipelineId=1, taskGroupId=1}, taskID=20000, index=0}],
pipelineActions={ActionStateKey(name=ActionStateKey - pipeline-1
[TransformChain[Transform[0]-sql]])=1, ActionStateKey(name=ActionStateKey -
pipeline-1 [Sink[0]-jdbc-MultiTableSink])=1, ActionStateKey(name=ActionStateKey
- pipeline-1 [
Source[0]-jdbc])=1},
subtaskActions={TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=816843488111886338,
pipelineId=1, taskGroupId=30000}, taskID=40000,
index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1
[TransformChain[Transform[0]-sql]]), 0), (ActionStateKey(name=ActionStateKey -
pipeline-1 [Source[0]-jdbc]), 0)],
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=816843488111886338,
pipelineId=1, taskGroupId=30000}, taskID=50000,
index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1
[Sink[0]-jdbc-MultiTableSink]), 0)],
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=816843488111886338,
pipelineId=1, taskGroupId=1}, taskID=20000,
index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-jdbc]),
-1)]}))
396
2024-03-04 09:24:23,885 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] is in state CREATED when init state future
397
2024-03-04 09:24:23,885 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] is in state CREATED when init state
future
398
2024-03-04 09:24:23,885 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job
SeaTunnel_Job (816843488111886338) state process is start
399
2024-03-04 09:24:23,887 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job
SeaTunnel_Job (816843488111886338) turned from state CREATED to SCHEDULED.
400
2024-03-04 09:24:23,887 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)] state process is start
401
2024-03-04 09:24:23,888 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)] turned from state CREATED to SCHEDULED.
402
2024-03-04 09:24:23,892 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)] turned from state SCHEDULED to
DEPLOYING.
403
2024-03-04 09:24:23,892 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] state process is start
404
2024-03-04 09:24:23,894 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] turned from state CREATED to DEPLOYING.
405
2024-03-04 09:24:23,898 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] turned from state DEPLOYING to RUNNING.
406
2024-03-04 09:24:23,898 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] current state equals target state:
RUNNING, skip
407
2024-03-04 09:24:23,898 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] state process is start
408
2024-03-04 09:24:23,899 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] turned from state CREATED to DEPLOYING.
409
2024-03-04 09:24:23,904 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] turned from state DEPLOYING to RUNNING.
410
2024-03-04 09:24:23,904 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] current state equals target state: RUNNING,
skip
411
2024-03-04 09:24:23,905 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)] turned from state DEPLOYING to RUNNING.
412
2024-03-04 09:24:23,907 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job
SeaTunnel_Job (816843488111886338) turned from state SCHEDULED to RUNNING.
413
2024-03-04 09:24:24,008 INFO
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator -
checkpoint is disabled, because in batch mode and 'checkpoint.interval' of env
is missing.
414
2024-03-04 09:24:24,200 INFO
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait
checkpoint completed: 9223372036854775807
415
2024-03-04 09:24:24,389 INFO
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - pending
checkpoint(9223372036854775807/1@816843488111886338) notify finished!
416
2024-03-04 09:24:24,389 INFO
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start
notify checkpoint completed, job id: 816843488111886338, pipeline id: 1,
checkpoint id:9223372036854775807
417
2024-03-04 09:24:24,392 INFO
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start
clean pending checkpoint cause CheckpointCoordinator completed.
418
2024-03-04 09:24:24,392 INFO
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn
checkpoint_state_816843488111886338_1 state from null to FINISHED
419
2024-03-04 09:24:24,402 INFO
org.apache.seatunnel.engine.server.CoordinatorService - [10.33.5.65]:5801
[seatunnel] [5.1] Received task end from execution
TaskGroupLocation{jobId=816843488111886338, pipelineId=1, taskGroupId=1}, state
FINISHED
420
2024-03-04 09:24:24,404 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] turned from state RUNNING to FINISHED.
421
2024-03-04 09:24:24,404 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] state process is stopped
422
2024-03-04 09:24:24,404 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SplitEnumerator (1/1)] future complete with state FINISHED
423
2024-03-04 09:24:24,423 INFO
org.apache.seatunnel.engine.server.CoordinatorService - [10.33.5.65]:5801
[seatunnel] [5.1] Received task end from execution
TaskGroupLocation{jobId=816843488111886338, pipelineId=1, taskGroupId=30000},
state FINISHED
424
2024-03-04 09:24:24,425 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] turned from state RUNNING to FINISHED.
425
2024-03-04 09:24:24,425 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] state process is stopped
426
2024-03-04 09:24:24,425 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)], task: [pipeline-1
[Source[0]-jdbc]-SourceTask (1/1)] future complete with state FINISHED
427
2024-03-04 09:24:24,425 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)] will end with state FINISHED
428
2024-03-04 09:24:24,426 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)] turned from state RUNNING to FINISHED.
429
2024-03-04 09:24:24,436 INFO
org.apache.seatunnel.engine.server.master.JobMaster - release the pipeline Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)] resource
430
2024-03-04 09:24:24,437 INFO
org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job
(816843488111886338), Pipeline: [(1/1)] state process is stop
431
2024-03-04 09:24:24,437 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job
SeaTunnel_Job (816843488111886338), Pipeline: [(1/1)] future complete with
state FINISHED
432
2024-03-04 09:24:24,439 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job
SeaTunnel_Job (816843488111886338) turned from state RUNNING to FINISHED.
433
2024-03-04 09:24:24,440 INFO
org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job
SeaTunnel_Job (816843488111886338) state process is stop
--
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]
