arthur1989Ng commented on issue #6854:
URL: https://github.com/apache/seatunnel/issues/6854#issuecomment-2111872490
Here is error message.
2024-05-15 11:44:07,412 INFO [o.a.s.e.s.CoordinatorService ]
[pool-6-thread-1] - [xx.xx.xx.230]:5801 [seatunnel] [5.1]
***********************************************
CoordinatorService Thread Pool Status
***********************************************
activeCount : 0
corePoolSize : 0
maximumPoolSize : 2147483647
poolSize : 0
completedTaskCount : 0
taskCount : 0
***********************************************
2024-05-15 11:44:19,116 INFO [o.a.h.i.e.RetryExec ]
[stream-load-upload] - I/O exception (java.net.SocketException) caught when
processing request to {}->http://xx.xx.xx.254:8040: Broken pipe (Write failed)
2024-05-15 11:44:25,709 ERROR [o.a.s.c.d.s.w.DorisSinkWriter ]
[stream-load-check] - stream load finished unexpectedly, interrupt worker
thread! org.apache.http.client.ClientProtocolException
2024-05-15 11:44:25,709 ERROR [s.c.m.MultiTableWriterRunnable]
[st-multi-table-sink-writer-1] - MultiTableWriterRunnable error
java.lang.RuntimeException: java.lang.InterruptedException
at
org.apache.seatunnel.connectors.doris.sink.writer.RecordStream.write(RecordStream.java:57)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.writeRecord(DorisStreamLoad.java:194)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:135)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:52)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:62)
~[seatunnel-transforms-v2.jar:2.3.5]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
Caused by: java.lang.InterruptedException
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
~[?:1.8.0_202]
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
~[?:1.8.0_202]
at
java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
~[?:1.8.0_202]
at
org.apache.seatunnel.connectors.doris.sink.writer.RecordBuffer.write(RecordBuffer.java:93)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.RecordStream.write(RecordStream.java:55)
~[?:?]
... 9 more
2024-05-15 11:44:26,136 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - [xx.xx.xx.230]:5801 [seatunnel] [5.1] Exception in
org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@5128cc0
java.lang.RuntimeException: java.lang.RuntimeException:
java.lang.RuntimeException: java.lang.InterruptedException
at
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:262)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:68)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:75)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:50)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:703)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1004)
~[seatunnel-starter.jar:2.3.5]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
Caused by: java.lang.RuntimeException: java.lang.RuntimeException:
java.lang.InterruptedException
at
org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:121)
~[seatunnel-transforms-v2.jar:2.3.5]
at
org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:158)
~[seatunnel-transforms-v2.jar:2.3.5]
at
org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:43)
~[seatunnel-transforms-v2.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:252)
~[seatunnel-starter.jar:2.3.5]
... 16 more
Caused by: java.lang.RuntimeException: java.lang.InterruptedException
at
org.apache.seatunnel.connectors.doris.sink.writer.RecordStream.write(RecordStream.java:57)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.writeRecord(DorisStreamLoad.java:194)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:135)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:52)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:62)
~[seatunnel-transforms-v2.jar:2.3.5]
... 5 more
Caused by: java.lang.InterruptedException
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
~[?:1.8.0_202]
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
~[?:1.8.0_202]
at
java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
~[?:1.8.0_202]
at
org.apache.seatunnel.connectors.doris.sink.writer.RecordBuffer.write(RecordBuffer.java:93)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.RecordStream.write(RecordStream.java:55)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad.writeRecord(DorisStreamLoad.java:194)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:135)
~[?:?]
at
org.apache.seatunnel.connectors.doris.sink.writer.DorisSinkWriter.write(DorisSinkWriter.java:52)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:62)
~[seatunnel-transforms-v2.jar:2.3.5]
... 5 more
2024-05-15 11:44:26,136 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - [xx.xx.xx.230]:5801 [seatunnel] [5.1] taskDone, taskId =
50000, taskGroup = TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}
2024-05-15 11:44:38,433 WARN [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - [xx.xx.xx.230]:5801 [seatunnel] [5.1] Exception in
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@266a1b60
java.lang.RuntimeException: java.lang.InterruptedException
at
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:41)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:46)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:28)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:204)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.collect(SeaTunnelSourceCollector.java:119)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceReader.pollNext(JdbcSourceReader.java:70)
~[?:?]
at
org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:156)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:116)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:121)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:703)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1004)
~[seatunnel-starter.jar:2.3.5]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
Caused by: java.lang.InterruptedException
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
~[?:1.8.0_202]
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
~[?:1.8.0_202]
at
java.util.concurrent.ArrayBlockingQueue.put(ArrayBlockingQueue.java:353)
~[?:1.8.0_202]
at
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:75)
~[seatunnel-starter.jar:2.3.5]
at
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:39)
~[seatunnel-starter.jar:2.3.5]
... 16 more
2024-05-15 11:44:38,433 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - [xx.xx.xx.230]:5801 [seatunnel] [5.1] taskDone, taskId =
40000, taskGroup = TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}
2024-05-15 11:44:38,434 INFO [.c.c.DefaultClassLoaderService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - Release classloader for job 842967299441819650 with jars
[file:/data/apache-seatunnel-2.3.5/connectors/connector-doris-2.3.5.jar,
file:/data/apache-seatunnel-2.3.5/plugins/jdbc/lib/mysql-connector-java-8.0.27.jar,
file:/data/apache-seatunnel-2.3.5/connectors/connector-jdbc-2.3.5.jar]
2024-05-15 11:44:38,442 INFO [.c.c.DefaultClassLoaderService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread
BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}
2024-05-15 11:44:38,442 INFO [.c.c.DefaultClassLoaderService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread
mysql-cj-abandoned-connection-cleanup
2024-05-15 11:44:38,442 INFO [.c.c.DefaultClassLoaderService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread
ForkJoinPool.commonPool-worker-13
2024-05-15 11:44:38,442 INFO [.c.c.DefaultClassLoaderService]
[BlockingWorker-TaskGroupLocation{jobId=842967299441819650, pipelineId=1,
taskGroupId=30000}] - recycle classloader for thread
hz.main.seaTunnel.task.thread-71
2024-05-15 11:44:38,442 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-71] - [xx.xx.xx.230]:5801 [seatunnel] [5.1] Task
TaskGroupLocation{jobId=842967299441819650, pipelineId=1, taskGroupId=30000}
complete with state FAILED
2024-05-15 11:44:38,448 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.generic-operation.thread-39] - [xx.xx.xx.230]:5801 [seatunnel] [5.1]
Task (TaskGroupLocation{jobId=842967299441819650, pipelineId=1, taskGroupId=1})
need cancel.
--
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]
