lovezhou1990 commented on issue #6336:
URL: https://github.com/apache/seatunnel/issues/6336#issuecomment-1958596264
Discovering new anomalies:
2024-02-22 08:58:56,392 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-27] - wait checkpoint completed: 27782
2024-02-22 08:58:56,395 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-27] - pending
checkpoint(27782/2@812617486796062721) notify finished!
2024-02-22 08:58:56,395 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-27] - start notify checkpoint completed, job id:
812617486796062721, pipeline id: 2, checkpoint id:27782
2024-02-22 08:58:57,874 INFO [o.a.s.e.s.d.p.PhysicalPlan ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721)
turned from state RUNNING to CANCELING.
2024-02-22 08:58:57,874 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-27] - start clean pending checkpoint cause
Pipeline turn to end state.
2024-02-22 08:58:57,874 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-27] - Turn checkpoint_state_812617486796062721_1
state from RUNNING to CANCELED
2024-02-22 08:58:57,875 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)] turned from state RUNNING to CANCELING.
2024-02-22 08:58:57,875 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator
(1/1)] state process is start
2024-02-22 08:58:57,875 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator
(1/1)] turned from state RUNNING to CANCELING.
2024-02-22 08:58:57,875 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Send cancel Job datamonitor
(812617486796062721), Pipeline: [(1/2)], task: [pipeline-1
[Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] operator to member [localhost]:5801
2024-02-22 08:58:57,875 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-27] - [localhost]:5801 [seatunnel] [5.1] Task
(TaskGroupLocation{jobId=812617486796062721, pipelineId=1, taskGroupId=1}) need
cancel.
2024-02-22 08:58:57,875 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)]
state process is start
2024-02-22 08:58:57,875 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}] - [localhost]:5801 [seatunnel] [5.1] Interrupted task 20000 -
org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@2544bd88
2024-02-22 08:58:57,875 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId = 20000,
taskGroup = TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}
2024-02-22 08:58:57,875 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}] - recycle classloader
org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader@132557f
2024-02-22 08:58:57,876 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)]
turned from state RUNNING to CANCELING.
2024-02-22 08:58:57,876 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Send cancel Job datamonitor
(812617486796062721), Pipeline: [(1/2)], task: [pipeline-1
[Source[0]-MySQL-CDC]-SourceTask (1/1)] operator to member [localhost]:5801
2024-02-22 08:58:57,876 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-27] - [localhost]:5801 [seatunnel] [5.1] Task
(TaskGroupLocation{jobId=812617486796062721, pipelineId=1, taskGroupId=30000})
need cancel.
2024-02-22 08:58:57,876 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-27] - start clean pending checkpoint cause
Pipeline turn to end state.
2024-02-22 08:58:57,877 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - [localhost]:5801 [seatunnel] [5.1] Interrupted task 50000
- org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@2508776d
2024-02-22 08:58:57,877 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId =
50000, taskGroup = TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}
2024-02-22 08:58:57,877 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - [localhost]:5801 [seatunnel] [5.1] Exception in
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@3dd4c1c6
org.apache.seatunnel.common.utils.SeaTunnelException:
java.lang.InterruptedException: sleep interrupted
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:166)
~[seatunnel-transforms-v2.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:92)
~[seatunnel-transforms-v2.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:110)
~[?:?]
at
org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:150)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:116)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:121)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:643)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:944)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_144]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_144]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_144]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_144]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_144]
Caused by: java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method) ~[?:1.8.0_144]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:164)
~[seatunnel-transforms-v2.jar:2.3.4-SNAPSHOT]
... 13 more
2024-02-22 08:58:57,877 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId =
40000, taskGroup = TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}
2024-02-22 08:58:57,877 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader
org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader@21f134cb
2024-02-22 08:58:57,882 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-27] - Turn checkpoint_state_812617486796062721_2
state from RUNNING to CANCELED
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}] - recycle classloader for thread
connection-pool-192.168.1.188:3306 housekeeper
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}] - recycle classloader for thread
BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 8
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 5
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 17
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 9
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 15
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 14
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-1] - [localhost]:5801 [seatunnel] [5.1] Task
TaskGroupLocation{jobId=812617486796062721, pipelineId=1, taskGroupId=1}
complete with state CANCELED
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 7
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 19
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 12
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 18
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 16
2024-02-22 08:58:57,883 INFO [.e.IncrementalSourceEnumerator]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=1}] - Closing enumerator...
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.CoordinatorService ]
[hz.main.seaTunnel.task.thread-1] - [localhost]:5801 [seatunnel] [5.1] Received
task end from execution TaskGroupLocation{jobId=812617486796062721,
pipelineId=1, taskGroupId=1}, state CANCELED
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 10
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 6
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread
BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread
BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread pool-28-thread-1
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 1
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 20
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 2
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 11
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread
ForkJoinPool.commonPool-worker-8
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 13
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 3
2024-02-22 08:58:57,883 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 4
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(2/2)] turned from state RUNNING to CANCELING.
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(2/2)], task: [pipeline-2 [Source[1]-MySQL-CDC]-SplitEnumerator
(1/1)] state process is start
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-1] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator
(1/1)] turned from state CANCELING to CANCELED.
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-1] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator
(1/1)] state process is stopped
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-13] - [localhost]:5801 [seatunnel] [5.1] Task
TaskGroupLocation{jobId=812617486796062721, pipelineId=1, taskGroupId=30000}
complete with state CANCELED
2024-02-22 08:58:57,883 INFO [a.s.c.s.c.s.r.SourceReaderBase]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - Closing Source Reader.
2024-02-22 08:58:57,883 INFO [o.a.s.e.s.CoordinatorService ]
[hz.main.seaTunnel.task.thread-13] - [localhost]:5801 [seatunnel] [5.1]
Received task end from execution TaskGroupLocation{jobId=812617486796062721,
pipelineId=1, taskGroupId=30000}, state CANCELED
2024-02-22 08:58:57,884 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-29] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator
(1/1)] future complete with state CANCELED
2024-02-22 08:58:57,884 INFO [o.a.s.c.s.c.s.r.f.SplitFetcher]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=1,
taskGroupId=30000}] - Shutting down split fetcher 0
2024-02-22 08:58:57,884 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-13] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)]
turned from state CANCELING to CANCELED.
2024-02-22 08:58:57,884 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-13] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)]
state process is stopped
2024-02-22 08:58:57,884 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(2/2)], task: [pipeline-2 [Source[1]-MySQL-CDC]-SplitEnumerator
(1/1)] turned from state RUNNING to CANCELING.
2024-02-22 08:58:57,884 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-29] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)]
future complete with state CANCELED
2024-02-22 08:58:57,884 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-29] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)] will end with state CANCELED
2024-02-22 08:58:57,885 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Send cancel Job datamonitor
(812617486796062721), Pipeline: [(2/2)], task: [pipeline-2
[Source[1]-MySQL-CDC]-SplitEnumerator (1/1)] operator to member [localhost]:5801
2024-02-22 08:58:57,885 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-27] - [localhost]:5801 [seatunnel] [5.1] Task
(TaskGroupLocation{jobId=812617486796062721, pipelineId=2, taskGroupId=6}) need
cancel.
2024-02-22 08:58:57,885 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-29] - Job datamonitor (812617486796062721),
Pipeline: [(1/2)] turned from state CANCELING to CANCELED.
2024-02-22 08:58:57,885 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(2/2)], task: [pipeline-2 [Source[1]-MySQL-CDC]-SourceTask (1/1)]
state process is start
2024-02-22 08:58:57,885 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}] - [localhost]:5801 [seatunnel] [5.1] Interrupted task 70000 -
org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@5468c66a
2024-02-22 08:58:57,885 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId = 70000,
taskGroup = TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}
2024-02-22 08:58:57,885 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}] - recycle classloader
org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader@47ab2e18
2024-02-22 08:58:57,886 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Job datamonitor (812617486796062721),
Pipeline: [(2/2)], task: [pipeline-2 [Source[1]-MySQL-CDC]-SourceTask (1/1)]
turned from state RUNNING to CANCELING.
2024-02-22 08:58:57,886 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-27] - Send cancel Job datamonitor
(812617486796062721), Pipeline: [(2/2)], task: [pipeline-2
[Source[1]-MySQL-CDC]-SourceTask (1/1)] operator to member [localhost]:5801
2024-02-22 08:58:57,886 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-27] - [localhost]:5801 [seatunnel] [5.1] Task
(TaskGroupLocation{jobId=812617486796062721, pipelineId=2, taskGroupId=80000})
need cancel.
2024-02-22 08:58:57,886 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - [localhost]:5801 [seatunnel] [5.1] Interrupted task
100000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@22830a7f
2024-02-22 08:58:57,886 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId =
100000, taskGroup = TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}
2024-02-22 08:58:57,886 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - [localhost]:5801 [seatunnel] [5.1] Exception in
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@15b0e614
org.apache.seatunnel.common.utils.SeaTunnelException:
java.lang.InterruptedException: sleep interrupted
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:166)
~[seatunnel-transforms-v2.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:92)
~[seatunnel-transforms-v2.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:110)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:112)
~[seatunnel-transforms-v2.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:110)
~[?:?]
at
org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:150)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:116)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:121)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:643)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:944)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_144]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_144]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_144]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_144]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_144]
Caused by: java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method) ~[?:1.8.0_144]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:164)
~[seatunnel-transforms-v2.jar:2.3.4-SNAPSHOT]
... 15 more
2024-02-22 08:58:57,886 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId =
90000, taskGroup = TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}
2024-02-22 08:58:57,886 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader
org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader@77add642
2024-02-22 08:58:57,888 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}] - recycle classloader for thread
BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}
2024-02-22 08:58:57,888 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}] - recycle classloader for thread
connection-pool-192.168.1.188:3306 housekeeper
2024-02-22 08:58:57,888 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-4] - [localhost]:5801 [seatunnel] [5.1] Task
TaskGroupLocation{jobId=812617486796062721, pipelineId=2, taskGroupId=6}
complete with state CANCELED
2024-02-22 08:58:57,888 INFO [.e.IncrementalSourceEnumerator]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=6}] - Closing enumerator...
2024-02-22 08:58:57,888 INFO [o.a.s.e.s.CoordinatorService ]
[hz.main.seaTunnel.task.thread-4] - [localhost]:5801 [seatunnel] [5.1] Received
task end from execution TaskGroupLocation{jobId=812617486796062721,
pipelineId=2, taskGroupId=6}, state CANCELED
2024-02-22 08:58:57,889 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader for thread I/O dispatcher 14
2024-02-22 08:58:57,889 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader for thread I/O dispatcher 13
2024-02-22 08:58:57,889 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader for thread I/O dispatcher 16
2024-02-22 08:58:57,889 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader for thread I/O dispatcher 15
2024-02-22 08:58:57,889 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader for thread I/O dispatcher 3
2024-02-22 08:58:57,889 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader for thread pool-17-thread-1
2024-02-22 08:58:57,889 INFO [o.a.s.e.c.l.ClassLoaderUtil ]
[BlockingWorker-TaskGroupLocation{jobId=812617486796062721, pipelineId=2,
taskGroupId=80000}] - recycle classloader for thread I/O dispatcher 9
--
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]
