HeyChiang commented on issue #442: URL: https://github.com/apache/doris-flink-connector/issues/442#issuecomment-2247069387
 ` "Process -> (BMS_BATCH_DEF: Writer -> BMS_BATCH_DEF: Committer, BMS_LOT_DEF: Writer -> BMS_LOT_DEF: Committer, BMS_STORER_POS: Writer -> BMS_STORER_POS: Committer, BMS_ST_IO_DOC: Writer -> BMS_ST_IO_DOC: Committer, BMS_ST_IO_DTL: Writer -> BMS_ST_IO_DTL: Committer, BMS_SU_SET_DOC: Writer -> BMS_SU_SET_DOC: Committer, BMS_SU_SET_DTL: Writer -> BMS_SU_SET_DTL: Committer, GPCS_INSIDER: Writer -> GPCS_INSIDER: Committer, GPCS_PLACEPOINT: Writer -> GPCS_PLACEPOINT: Committer, GPCS_PLACEPOINT_CLASS: Writer -> GPCS_PLACEPOINT_CLASS: Committer, GPCS_PLACEPOINT_CLASS_DTL: Writer -> GPCS_PLACEPOINT_CLASS_DTL: Committer, GRESA_SA_DOC: Writer -> GRESA_SA_DOC: Committer, GRESA_SA_DTL: Writer -> GRESA_SA_DTL: Committer, NGPCS_ALL_PRICE: Writer -> NGPCS_ALL_PRICE: Committer, NP_EFILES_OP_FILE: Writer -> NP_EFILES_OP_FILE: Committer, PUB_BRAND: Writer -> PUB_BRAND: Committer, PUB_EMPLOYEE: Writer -> PUB_EMPLOYEE: Committer, PUB_FACTORY: Writer -> PUB_FACTORY: Committer, PUB_GOODS: Writer -> PUB_G OODS: Committer, PUB_GOODS_CLASS: Writer -> PUB_GOODS_CLASS: Committer, PUB_GOODS_CLASS_DTL: Writer -> PUB_GOODS_CLASS_DTL: Committer) (2/3)#0" Id=12810 WAITING on java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@24273330 at java.base@11.0.22/jdk.internal.misc.Unsafe.park(Native Method) - waiting on java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@24273330 at java.base@11.0.22/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.base@11.0.22/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) at java.base@11.0.22/java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:417) at org.apache.doris.flink.sink.writer.RecordBuffer.write(RecordBuffer.java:93) at org.apache.doris.flink.sink.writer.RecordStream.write(RecordStream.java:63) at org.apache.doris.flink.sink.writer.DorisStreamLoad.writeRecord(DorisStreamLoad.java:251) at org.apache.doris.flink.sink.writer.DorisWriter.writeOneDorisRecord(DorisWriter.java:216) at org.apache.doris.flink.sink.writer.DorisWriter.write(DorisWriter.java:186) at app//org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:160) at app//org.apache.flink.streaming.runtime.io.RecordProcessorUtils$$Lambda$825/0x00000008007eec40.accept(Unknown Source) at app//org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:75) at app//org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:61) at app//org.apache.flink.streaming.runtime.tasks.ChainingOutput.collectAndCheckIfChained(ChainingOutput.java:96) at app//org.apache.flink.streaming.runtime.tasks.BroadcastingOutputCollector.collect(BroadcastingOutputCollector.java:94) at app//org.apache.flink.streaming.api.operators.ProcessOperator$ContextImpl.output(ProcessOperator.java:103) at org.apache.doris.flink.tools.cdc.ParsingProcessFunction.processElement(ParsingProcessFunction.java:51) at org.apache.doris.flink.tools.cdc.ParsingProcessFunction.processElement(ParsingProcessFunction.java:31) at app//org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66) at app//org.apache.flink.streaming.runtime.io.RecordProcessorUtils$$Lambda$825/0x00000008007eec40.accept(Unknown Source) at app//org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:238) at app//org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:157) at app//org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:114) at app//org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) at app//org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:579) at app//org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$746/0x00000008006ff440.runDefaultAction(Unknown Source) at app//org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) at app//org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:909) at app//org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:858) at app//org.apache.flink.runtime.taskmanager.Task$$Lambda$1135/0x0000000800928c40.run(Unknown Source) at app//org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) at app//org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) at app//org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:751) at app//org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) at java.base@11.0.22/java.lang.Thread.run(Thread.java:834) ` -- 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: commits-unsubscr...@doris.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org
