qihongjun opened a new issue, #9224: URL: https://github.com/apache/seatunnel/issues/9224
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened Oracle CDC 往 Oracle同步多张表数据。运行10分钟左右报以下错误。调试了checkpoint.interval，source.reader.close.timeout 等多个参数均无效果。 ### SeaTunnel Version SeaTunnel 2.3.10 ### SeaTunnel Config ```conf env { # You can set SeaTunnel environment configuration here parallelism = 4 job.mode = "STREAMING" checkpoint.interval = 2000 } source { # This is a example source plugin **only for test and demonstrate the feature source plugin** Oracle-CDC { driver = "oracle.jdbc.driver.OracleDriver" plugin_output = "o_las_test" username = "seatunnel" password = "Snnelsss521" database-names = ["SX9DB"] schema-names = ["LAS05"] table-names = ["SX9DB.LAS05.TEST"] base-url = "jdbc:oracle:thin:@10.10.163.31:1521/SX9DB" source.reader.close.timeout = 600000 #600S connection.pool.size = 1 # 启用DDL schema-changes.enabled = true # 跳过表分析 表分析时间过长会导致在初始化的时候任务中断 skip_analyze = true } Oracle-CDC { driver = "oracle.jdbc.driver.OracleDriver" plugin_output = "o_las_lrpd" username = "seatunnel" password = "Snnelsss521" database-names = ["SX9DB"] schema-names = ["LAS03"] table-names = ["SX9DB.LAS03.LAS_REPAYING_PLAN_DETAIL"] table-names-config = [ { table = "SX9DB.LAS03.LAS_REPAYING_PLAN_DETAIL" primaryKeys = ["REPAYING_PLAN_DETAIL_ID"] } ] base-url = "jdbc:oracle:thin:@10.10.163.31:1521/SX9DB" source.reader.close.timeout = 600000 connection.pool.size = 2 schema-changes.enabled = true skip_analyze = true } ``` ### Running Command ```shell bin/seatunnel.sh --config $SEATUNNEL_HOME/config/c_las_to_bosbank.conf ``` ### Error Exception ```log [967634792520613889] 2025-04-24 12:08:50,871 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=967634792520613889, pipelineId=3, taskGroupId=12}] - [seatunnel01]:5802 [sx-seatunnel] [5.1] taskDone, taskId = 3001200000000, taskGroup = TaskGroupLocation{jobId=967634792520613889, pipelineId=3, taskGroupId=12} [967634792520613889] 2025-04-24 12:08:50,872 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=967634792520613889, pipelineId=3, taskGroupId=12}] - [seatunnel01]:5802 [sx-seatunnel] [5.1] Exception in org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@4f604a53 java.lang.RuntimeException: java.io.IOException: java.lang.InterruptedException at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:302) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:75) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:50) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) ~[seatunnel-starter.jar:2.3.10] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] Caused by: java.io.IOException: java.lang.InterruptedException at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:209) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:47) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:268) ~[seatunnel-starter.jar:2.3.10] ... 17 more Caused by: java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014) ~[?:1.8.0_191] at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2088) ~[?:1.8.0_191] at java.util.concurrent.LinkedBlockingQueue.offer(LinkedBlockingQueue.java:385) ~[?:1.8.0_191] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:204) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:47) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:268) ~[seatunnel-starter.jar:2.3.10] ... 17 more [967634792520613889] 2025-04-24 12:08:52,031 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=967634792520613889, pipelineId=2, taskGroupId=8}] - [seatunnel01]:5802 [sx-seatunnel] [5.1] Exception in org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@2a774bef java.lang.RuntimeException: java.lang.RuntimeException: java.lang.InterruptedException: sleep interrupted at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:302) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:70) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:50) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) ~[seatunnel-starter.jar:2.3.10] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] Caused by: java.lang.RuntimeException: java.lang.InterruptedException: sleep interrupted at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.checkQueueRemain(MultiTableSinkWriter.java:362) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.prepareCommit(MultiTableSinkWriter.java:239) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:201) ~[seatunnel-starter.jar:2.3.10] ... 17 more Caused by: java.lang.InterruptedException: sleep interrupted at java.lang.Thread.sleep(Native Method) ~[?:1.8.0_191] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.checkQueueRemain(MultiTableSinkWriter.java:357) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.prepareCommit(MultiTableSinkWriter.java:239) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:201) ~[seatunnel-starter.jar:2.3.10] ... 17 more [967634792520613889] 2025-04-24 12:08:52,031 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=967634792520613889, pipelineId=2, taskGroupId=8}] - [seatunnel01]:5802 [sx-seatunnel] [5.1] taskDone, taskId = 2000800010001, taskGroup = TaskGroupLocation{jobId=967634792520613889, pipelineId=2, taskGroupId=8} [967634792520613889] 2025-04-24 12:08:52,045 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=967634792520613889, pipelineId=2, taskGroupId=8}] - [seatunnel01]:5802 [sx-seatunnel] [5.1] taskGroup TaskGroupLocation{jobId=967634792520613889, pipelineId=2, taskGroupId=8} complete with CANCELED [967634792520613889] 2025-04-24 12:08:52,045 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-142] - [seatunnel01]:5802 [sx-seatunnel] [5.1] Task TaskGroupLocation{jobId=967634792520613889, pipelineId=2, taskGroupId=8} complete with state CANCELED ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version # java -version java version "1.8.0_191" Java(TM) SE Runtime Environment (build 1.8.0_191-b12) Java HotSpot(TM) 64-Bit Server VM (build 25.191-b12, mixed mode) ### Screenshots _No response_ ### Are you willing to submit PR? - [x] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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]
