x-otto-x commented on issue #4588:
URL:
https://github.com/apache/incubator-seatunnel/issues/4588#issuecomment-1512731161
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.1]
at
org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:46)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:28)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:72)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.collect(SeaTunnelSourceCollector.java:56)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceRecordEmitter$OutputCollector.collect(IncrementalSourceRecordEmitter.java:153)
~[connector-cdc-mysql-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.connectors.cdc.debezium.row.SeaTunnelRowDebeziumDeserializeSchema.deserialize(SeaTunnelRowDebeziumDeserializeSchema.java:142)
~[connector-cdc-mysql-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceRecordEmitter.emitElement(IncrementalSourceRecordEmitter.java:145)
~[connector-cdc-mysql-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceRecordEmitter.processElement(IncrementalSourceRecordEmitter.java:120)
~[connector-cdc-mysql-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceRecordEmitter.emitRecord(IncrementalSourceRecordEmitter.java:85)
~[connector-cdc-mysql-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceRecordEmitter.emitRecord(IncrementalSourceRecordEmitter.java:51)
~[connector-cdc-mysql-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:108)
~[connector-jdbc-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:92)
~[connector-cdc-mysql-2.3.1.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:135)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:84)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:161)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:89)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:526)
[seatunnel-starter.jar:2.3.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_362]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[?:1.8.0_362]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_362]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_362]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_362]
Caused by: java.lang.InterruptedException
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
~[?:1.8.0_362]
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
~[?:1.8.0_362]
at
java.util.concurrent.ArrayBlockingQueue.put(ArrayBlockingQueue.java:353)
~[?:1.8.0_362]
at
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:76)
~[seatunnel-starter.jar:2.3.1]
at
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:39)
~[seatunnel-starter.jar:2.3.1]
... 22 more
2023-04-18 17:06:25,344 INFO
org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801
[seatunnel-979811] [5.1] taskDone, taskId = 40000, taskGroup =
TaskGroupLocation{jobId=700630831856615425, pipelineId=1, taskGroupId=30000}
--
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]
