yrg5101 opened a new issue, #19461: URL: https://github.com/apache/doris/issues/19461
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/doris/issues?q=is%3Aissue) and found no similar issues. ### Version Doris:1.2.4rc Mysql:8.0.22 FlinkCDC:2.3 Flink:1.16.1 ### What's Wrong? Doris:1.2.4rc Mysql:8.0.22 FlinkCDC:2.3 Flink:1.16.1 Caused by: java.lang.Exception: Could not perform checkpoint 53 for operator Source: MySQL CDC Source -> (Filter -> sink test123: Writer -> sink test123: Committer, Filter -> sink test234: Writer -> sink test234: Committer) (5/16)#0. at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointAsyncInMailbox(StreamTask.java:1141) at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$triggerCheckpointAsync$11(StreamTask.java:1088) at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:338) at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:324) at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201) at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:807) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:756) at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.doris.flink.exception.DorisRuntimeException: java.util.concurrent.ExecutionException: java.net.SocketTimeoutException: Read timed out at org.apache.doris.flink.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:220) at org.apache.doris.flink.sink.writer.DorisWriter.prepareCommit(DorisWriter.java:139) at org.apache.flink.streaming.api.transformations.SinkV1Adapter$SinkWriterV1Adapter.prepareCommit(SinkV1Adapter.java:151) at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.emitCommittables(SinkWriterOperator.java:198) at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.prepareSnapshotPreBarrier(SinkWriterOperator.java:168) at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.prepareSnapshotPreBarrier(RegularOperatorChain.java:89) at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:300) at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$12(StreamTask.java:1256) at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) at org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1244) at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointAsyncInMailbox(StreamTask.java:1129) ... 13 more Caused by: java.util.concurrent.ExecutionException: java.net.SocketTimeoutException: Read timed out at java.util.concurrent.FutureTask.report(FutureTask.java:122) at java.util.concurrent.FutureTask.get(FutureTask.java:192) at org.apache.doris.flink.sink.writer.DorisStreamLoad.stopLoad(DorisStreamLoad.java:218) ... 23 more Caused by: java.net.SocketTimeoutException: Read timed out at java.net.SocketInputStream.socketRead0(Native Method) at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) at java.net.SocketInputStream.read(SocketInputStream.java:171) at java.net.SocketInputStream.read(SocketInputStream.java:141) at org.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:139) at org.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:155) at org.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:284) at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:140) at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:57) at org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:261) at org.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:165) at org.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:167) at org.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:272) at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:124) at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:271) at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:184) at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:88) at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:184) at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82) at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:107) at org.apache.doris.flink.sink.writer.DorisStreamLoad.lambda$startLoad$0(DorisStreamLoad.java:248) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ... 1 more Be日志： W0509 17:54:57.858546 161810 stream_load_executor.cpp:80] fragment execute failed, query_id=a0497541bdcfad7f-510b41fe885b7797, err_msg=[INTERNAL_ERROR]cancelled: sender is gone, id=a0497541bdcfad7f-510b41fe885b7797, job_id=-1, txn_id=18031, label=label-GAIA_STORE_DATA67c73863-56fc-40c4-8d40-a2cf3056dc40_6_387, elapse(s)=1 W0509 17:57:45.168293 161959 scanner_scheduler.cpp:256] Scan thread read VScanner failed: [INTERNAL_ERROR]cancelled: sender is gone W0509 17:57:45.168517 161871 fragment_mgr.cpp:118] query_id=b74af8c9d7d2aa8e-a79bd1490e27c282, instance_id=b74af8c9d7d2aa8e-a79bd1490e27c283 meet error status [INTERNAL_ERROR]cancelled: sender is gone W0509 17:57:45.168582 161871 fragment_mgr.cpp:405] report error status: [INTERNAL_ERROR]cancelled: sender is gone to coordinator: TNetworkAddress(hostname=172.18.2.103, port=9020), query id: b74af8c9d7d2aa8e-a79bd1490e27c282, instance id: b74af8c9d7d2aa8e-a79bd1490e27c283 W0509 17:57:45.169206 161871 fragment_mgr.cpp:261] Got error while opening fragment b74af8c9d7d2aa8e-a79bd1490e27c283, query id: b74af8c9d7d2aa8e-a79bd1490e27c282: [INTERNAL_ERROR]cancelled: sender is gone W0509 17:57:45.169502 161871 tablet_sink.cpp:156] cancel node channel VNodeChannel[441110-10005], load_id=b74af8c9d7d2aa8e-a79bd1490e27c282, txn_id=18037, node=172.18.2.106:8060, error message: [INTERNAL_ERROR]cancelled: sender is gone W0509 17:57:45.169621 161871 tablet_sink.cpp:156] cancel node channel VNodeChannel[441110-10004], load_id=b74af8c9d7d2aa8e-a79bd1490e27c282, txn_id=18037, node=172.18.2.105:8060, error message: [INTERNAL_ERROR]cancelled: sender is gone W0509 17:57:45.169683 161871 tablet_sink.cpp:156] cancel node channel VNodeChannel[441110-10003], load_id=b74af8c9d7d2aa8e-a79bd1490e27c282, txn_id=18037, node=172.18.2.104:8060, error message: [INTERNAL_ERROR]cancelled: sender is gone W0509 17:57:45.170018 161871 stream_load_executor.cpp:80] fragment execute failed, query_id=b74af8c9d7d2aa8e-a79bd1490e27c282, err_msg=[INTERNAL_ERROR]cancelled: sender is gone, id=b74af8c9d7d2aa8e-a79bd1490e27c282, job_id=-1, txn_id=18037, label=label-test_tianyz_01e6ab150d-9fc0-409f-aaea-4904f1b272ae_0_3, elapse(s)=9 ### What You Expected? 麻烦看看，谢谢 ### How to Reproduce? _No response_ ### Anything Else? _No response_ ### Are you willing to submit PR? - [ ] 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
