【已解决】flink cdc sqlserver 往doris 写数据 报错

Viewed 107

doris 版本 2.0.13
flink 版本 1.17.1
cdc 版本

        <dependency>
            <groupId>com.ververica</groupId>
            <artifactId>flink-connector-sqlserver-cdc</artifactId>
            <version>2.4.2-self</version>
        </dependency>

cdc 报错日志






2025-01-06 12:37:06 633 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 897913 records for table 'SPxSSC.dbo.nxinventory' after 00:01:30.485
2025-01-06 12:37:16 634 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1000306 records for table 'SPxSSC.dbo.nxinventory' after 00:01:40.486
2025-01-06 12:37:26 635 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1103956 records for table 'SPxSSC.dbo.nxinventory' after 00:01:50.487
2025-01-06 12:37:36 654 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1207161 records for table 'SPxSSC.dbo.nxinventory' after 00:02:00.506
2025-01-06 12:37:46 656 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1309561 records for table 'SPxSSC.dbo.nxinventory' after 00:02:10.508
2025-01-06 12:37:56 683 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1414009 records for table 'SPxSSC.dbo.nxinventory' after 00:02:20.535
2025-01-06 12:38:06 780 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1518457 records for table 'SPxSSC.dbo.nxinventory' after 00:02:30.631
2025-01-06 12:38:10 793 [debezium-engine] [io.debezium.connector.common.BaseSourceTask] [INFO] - 819200 records sent during previous 00:01:19.923, last recorded offset: {commit_lsn=0002f784:00000b80:0001, snapshot=true, snapshot_completed=false}
2025-01-06 12:38:16 781 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1621918 records for table 'SPxSSC.dbo.nxinventory' after 00:02:40.633
2025-01-06 12:38:26 782 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1726500 records for table 'SPxSSC.dbo.nxinventory' after 00:02:50.634
2025-01-06 12:38:36 783 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1829688 records for table 'SPxSSC.dbo.nxinventory' after 00:03:00.635
2025-01-06 12:38:46 888 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 1934201 records for table 'SPxSSC.dbo.nxinventory' after 00:03:10.74
2025-01-06 12:38:56 959 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 2038649 records for table 'SPxSSC.dbo.nxinventory' after 00:03:20.811
2025-01-06 12:39:06 960 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 2143127 records for table 'SPxSSC.dbo.nxinventory' after 00:03:30.812
2025-01-06 12:39:17 016 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 2247545 records for table 'SPxSSC.dbo.nxinventory' after 00:03:40.868
2025-01-06 12:39:27 107 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 2354041 records for table 'SPxSSC.dbo.nxinventory' after 00:03:50.959
2025-01-06 12:39:37 227 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 2458489 records for table 'SPxSSC.dbo.nxinventory' after 00:04:01.079
2025-01-06 12:39:47 252 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 2562937 records for table 'SPxSSC.dbo.nxinventory' after 00:04:11.104
2025-01-06 12:39:57 375 [debezium-sqlserverconnector-sqlserver_transaction_log_source-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] [INFO] - 	 Exported 2669433 records for table 'SPxSSC.dbo.nxinventory' after 00:04:21.227
2025-01-06 12:40:05 413 [stream-load-upload-thread-1] [org.apache.http.impl.execchain.RetryExec] [INFO] - I/O exception (java.net.SocketException) caught when processing request to {}->http://172.31.3.70:8040: Software caused connection abort: socket write error
2025-01-06 12:40:05 687 [stream-load-check-thread-1] [org.apache.doris.flink.sink.writer.DorisWriter] [ERROR] - stream load finished unexpectedly, interrupt worker thread! org.apache.http.client.ClientProtocolException
2025-01-06 12:40:05 699 [nxinventory: Writer -> nxinventory: Committer (1/1)#0] [org.apache.flink.runtime.taskmanager.Task] [WARN] - nxinventory: Writer -> nxinventory: Committer (1/1)#0 (b680262b37bf1e82a91460823e8dcb1f_e70bbd798b564e0a50e10e343f1ac56b_0_0) switched from RUNNING to FAILED with failure cause: java.lang.RuntimeException: java.lang.InterruptedException
	at org.apache.doris.flink.sink.writer.RecordStream.write(RecordStream.java:59)
	at org.apache.doris.flink.sink.writer.DorisStreamLoad.writeRecord(DorisStreamLoad.java:195)
	at org.apache.doris.flink.sink.writer.DorisWriter.write(DorisWriter.java:143)
	at org.apache.flink.streaming.api.transformations.SinkV1Adapter$SinkWriterV1Adapter.write(SinkV1Adapter.java:136)
	at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:160)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)
	at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
	at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
	at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:542)
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:831)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:780)
	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914)
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
	at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
	at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
	at org.apache.doris.flink.sink.writer.RecordBuffer.write(RecordBuffer.java:91)
	at org.apache.doris.flink.sink.writer.RecordStream.write(RecordStream.java:57)
	... 17 more

2025-01-06 12:40:05 700 [nxinventory: Writer -> nxinventory: Committer (1/1)#0] [org.apache.flink.runtime.taskmanager.Task] [INFO] - Freeing task resources for nxinventory: Writer -> nxinventory: Committer (1/1)#0 (b680262b37bf1e82a91460823e8dcb1f_e70bbd798b564e0a50e10e343f1ac56b_0_0).
2025-01-06 12:40:05 706 [flink-akka.actor.default-dispatcher-62] [org.apache.flink.runtime.taskexecutor.TaskExecutor] [INFO] - Un-registering task and sending final execution state FAILED to JobManager for task nxinventory: Writer -> nxinventory: Committer (1/1)#0 b680262b37bf1e82a91460823e8dcb1f_e70bbd798b564e0a50e10e343f1ac56b_0_0.
2025-01-06 12:40:05 712 [flink-akka.actor.default-dispatcher-63] [org.apache.flink.runtime.executiongraph.ExecutionGraph] [INFO] - nxinventory: Writer -> nxinventory: Committer (1/1) (b680262b37bf1e82a91460823e8dcb1f_e70bbd798b564e0a50e10e343f1ac56b_0_0) switched from RUNNING to FAILED on 6300ab66-d705-4143-abf7-701a786a4653 @ 127.0.0.1 (dataPort=-1).
java.lang.RuntimeException: java.lang.InterruptedException
	at org.apache.doris.flink.sink.writer.RecordStream.write(RecordStream.java:59)
	at org.apache.doris.flink.sink.writer.DorisStreamLoad.writeRecord(DorisStreamLoad.java:195)
	at org.apache.doris.flink.sink.writer.DorisWriter.write(DorisWriter.java:143)
	at org.apache.flink.streaming.api.transformations.SinkV1Adapter$SinkWriterV1Adapter.write(SinkV1Adapter.java:136)
	at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:160)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)
	at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
	at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
	at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:542)
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:831)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:780)
	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914)
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
	at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
	at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
	at org.apache.doris.flink.sink.writer.RecordBuffer.write(RecordBuffer.java:91)
	at org.apache.doris.flink.sink.writer.RecordStream.write(RecordStream.java:57)
	... 17 more
2025-01-06 12:40:05 721 [flink-akka.actor.default-dispatcher-63] [org.apache.flink.runtime.jobmaster.JobMaster] [INFO] - 10 tasks will be restarted to recover the failed task b680262b37bf1e82a91460823e8dcb1f_e70bbd798b564e0a50e10e343f1ac56b_0_0.
2025-01-06 12:40:05 721 [flink-akka.actor.default-dispatcher-63] [org.apache.flink.runtime.executiongraph.ExecutionGraph] [INFO] - Job Doris Sync Database: spxssc (042975d4ff8002c61d8b82fe033054b6) switched from state RUNNING to RESTARTING.
2025-01-06 12:40:05 725 [flink-akka.actor.default-dispatcher-63] [org.apache.flink.runtime.checkpoint.CheckpointFailureManager] [WARN] - Failed to trigger or complete checkpoint 1 for job 042975d4ff8002c61d8b82fe033054b6. (0 consecutive failed attempts so far)
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint Coordinator is suspending.
	at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.stopCheckpointScheduler(CheckpointCoordinator.java:1926)
	at org.apache.flink.runtime.checkpoint.CheckpointCoordinatorDeActivator.jobStatusChanges(CheckpointCoordinatorDeActivator.java:46)
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifyJobStatusChange(DefaultExecutionGraph.java:1566)
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.transitionState(DefaultExecutionGraph.java:1161)
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.transitionState(DefaultExecutionGraph.java:1133)
	at org.apache.flink.runtime.scheduler.SchedulerBase.transitionExecutionGraphState(SchedulerBase.java:571)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.addVerticesToRestartPending(DefaultScheduler.java:362)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.restartTasksWithDelay(DefaultScheduler.java:334)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeRestartTasks(DefaultScheduler.java:305)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240)
	at org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:738)
	at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:715)
	at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
	at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:477)
	at sun.reflect.GeneratedMethodAccessor16.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309)
	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
	at akka.actor.Actor.aroundReceive(Actor.scala:537)
	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
	at akka.actor.ActorCell.receiveMessage$$$capture(ActorCell.scala:580)
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala)
	at akka.actor.ActorCell.invoke(ActorCell.scala:548)
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
	at java.util.concurrent.ForkJoinTask.doExec$$$capture(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1067)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1703)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:172)

fe 日志

2025-01-06 12:40:01,625 WARN (mysql-nio-pool-1773|344911) [StmtExecutor.handleDdlStmt():2446] 
org.apache.doris.qe.QueryStateException: errCode = 2, detailMessage = {'label':'delete_263a40de-7625-4247-847d-f4f587e227af', 'status':'VISIBLE', 'txnId':'235254254'}
	at org.apache.doris.load.DeleteHandler.commitJob(DeleteHandler.java:526) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.load.DeleteHandler.process(DeleteHandler.java:406) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:184) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:432) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.dispatch(ConnectProcessor.java:584) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.processOnce(ConnectProcessor.java:853) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:01,710 WARN (mysql-nio-pool-1772|344730) [ConnectProcessor.processOnce():843] Null packet received from network. remote: 172.31.3.76:57212
2025-01-06 12:40:01,710 WARN (mysql-nio-pool-1772|344730) [ReadListener.lambda$handleEvent$0():60] Exception happened in one session(org.apache.doris.qe.ConnectContext@731312d3).
java.io.IOException: Error happened when receiving packet.
	at org.apache.doris.qe.ConnectProcessor.processOnce(ConnectProcessor.java:844) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:01,746 WARN (mysql-nio-pool-1773|344911) [ConnectProcessor.processOnce():843] Null packet received from network. remote: 172.31.3.76:56690
2025-01-06 12:40:01,746 WARN (mysql-nio-pool-1773|344911) [ReadListener.lambda$handleEvent$0():60] Exception happened in one session(org.apache.doris.qe.ConnectContext@5c67cd99).
java.io.IOException: Error happened when receiving packet.
	at org.apache.doris.qe.ConnectProcessor.processOnce(ConnectProcessor.java:844) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:01,930 WARN (mysql-nio-pool-1773|344911) [StmtExecutor.handleDdlStmt():2446] 
org.apache.doris.qe.QueryStateException: errCode = 2, detailMessage = {'label':'delete_6c9d8660-b1ac-4bec-bade-de577062567e', 'status':'VISIBLE', 'txnId':'235254263'}
	at org.apache.doris.load.DeleteHandler.commitJob(DeleteHandler.java:526) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.load.DeleteHandler.process(DeleteHandler.java:406) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:184) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.util.StatisticsUtil.execUpdate(StatisticsUtil.java:155) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.executeDropSql(StatisticsRepository.java:236) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatisticsByColName(StatisticsRepository.java:224) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatistics(StatisticsRepository.java:200) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.AnalysisManager.dropStats(AnalysisManager.java:691) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.datasource.InternalCatalog.truncateTable(InternalCatalog.java:3141) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.catalog.Env.truncateTable(Env.java:5069) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:234) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:432) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.dispatch(ConnectProcessor.java:584) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.processOnce(ConnectProcessor.java:853) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:01,992 WARN (mysql-nio-pool-1773|344911) [StmtExecutor.handleDdlStmt():2446] 
org.apache.doris.qe.QueryStateException: errCode = 2, detailMessage = {'label':'delete_41ba2362-3e53-4ae6-9dfb-0abffc6f97a1', 'status':'VISIBLE', 'txnId':'235254285'}
	at org.apache.doris.load.DeleteHandler.commitJob(DeleteHandler.java:526) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.load.DeleteHandler.process(DeleteHandler.java:406) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:184) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.util.StatisticsUtil.execUpdate(StatisticsUtil.java:155) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.executeDropSql(StatisticsRepository.java:236) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatisticsByColName(StatisticsRepository.java:224) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatistics(StatisticsRepository.java:201) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.AnalysisManager.dropStats(AnalysisManager.java:691) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.datasource.InternalCatalog.truncateTable(InternalCatalog.java:3141) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.catalog.Env.truncateTable(Env.java:5069) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:234) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:432) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.dispatch(ConnectProcessor.java:584) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.processOnce(ConnectProcessor.java:853) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:02,340 WARN (thrift-server-pool-26195|332711) [StmtExecutor.handleDdlStmt():2446] 
org.apache.doris.qe.QueryStateException: errCode = 2, detailMessage = {'label':'delete_c0fdd942-4b49-4a36-ac27-befab05b2835', 'status':'VISIBLE', 'txnId':'235254312'}
	at org.apache.doris.load.DeleteHandler.commitJob(DeleteHandler.java:526) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.load.DeleteHandler.process(DeleteHandler.java:406) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:184) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.util.StatisticsUtil.execUpdate(StatisticsUtil.java:155) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.executeDropSql(StatisticsRepository.java:236) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatisticsByColName(StatisticsRepository.java:224) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatistics(StatisticsRepository.java:200) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.AnalysisManager.dropStats(AnalysisManager.java:691) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.datasource.InternalCatalog.truncateTable(InternalCatalog.java:3141) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.catalog.Env.truncateTable(Env.java:5069) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:234) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:507) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.proxyExecute(ConnectProcessor.java:784) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.service.FrontendServiceImpl.forward(FrontendServiceImpl.java:1096) ~[doris-fe.jar:1.2-SNAPSHOT]
	at sun.reflect.GeneratedMethodAccessor66.invoke(Unknown Source) ~[?:?]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_281]
	at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_281]
	at org.apache.doris.service.FeServer.lambda$start$0(FeServer.java:60) ~[doris-fe.jar:1.2-SNAPSHOT]
	at com.sun.proxy.$Proxy34.forward(Unknown Source) ~[?:?]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3132) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3112) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:250) ~[libthrift-0.16.0.jar:0.16.0]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:02,378 WARN (thrift-server-pool-26195|332711) [StmtExecutor.handleDdlStmt():2446] 
org.apache.doris.qe.QueryStateException: errCode = 2, detailMessage = {'label':'delete_033823c0-5b5d-4fc6-ae2d-4aa5a75aaaab', 'status':'VISIBLE', 'txnId':'235254334'}
	at org.apache.doris.load.DeleteHandler.commitJob(DeleteHandler.java:526) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.load.DeleteHandler.process(DeleteHandler.java:406) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:184) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.util.StatisticsUtil.execUpdate(StatisticsUtil.java:155) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.executeDropSql(StatisticsRepository.java:236) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatisticsByColName(StatisticsRepository.java:224) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatistics(StatisticsRepository.java:201) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.AnalysisManager.dropStats(AnalysisManager.java:691) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.datasource.InternalCatalog.truncateTable(InternalCatalog.java:3141) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.catalog.Env.truncateTable(Env.java:5069) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:234) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:507) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.proxyExecute(ConnectProcessor.java:784) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.service.FrontendServiceImpl.forward(FrontendServiceImpl.java:1096) ~[doris-fe.jar:1.2-SNAPSHOT]
	at sun.reflect.GeneratedMethodAccessor66.invoke(Unknown Source) ~[?:?]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_281]
	at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_281]
	at org.apache.doris.service.FeServer.lambda$start$0(FeServer.java:60) ~[doris-fe.jar:1.2-SNAPSHOT]
	at com.sun.proxy.$Proxy34.forward(Unknown Source) ~[?:?]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3132) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3112) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:250) ~[libthrift-0.16.0.jar:0.16.0]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:03,365 WARN (thrift-server-pool-26195|332711) [StmtExecutor.handleDdlStmt():2446] 
org.apache.doris.qe.QueryStateException: errCode = 2, detailMessage = {'label':'delete_359d3252-8dfb-48a9-a77d-7ff7357e8c1e', 'status':'VISIBLE', 'txnId':'235254368'}
	at org.apache.doris.load.DeleteHandler.commitJob(DeleteHandler.java:526) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.load.DeleteHandler.process(DeleteHandler.java:406) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:184) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.util.StatisticsUtil.execUpdate(StatisticsUtil.java:155) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.executeDropSql(StatisticsRepository.java:236) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatisticsByColName(StatisticsRepository.java:224) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatistics(StatisticsRepository.java:200) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.AnalysisManager.dropStats(AnalysisManager.java:691) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.datasource.InternalCatalog.truncateTable(InternalCatalog.java:3141) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.catalog.Env.truncateTable(Env.java:5069) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:234) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:507) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.proxyExecute(ConnectProcessor.java:784) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.service.FrontendServiceImpl.forward(FrontendServiceImpl.java:1096) ~[doris-fe.jar:1.2-SNAPSHOT]
	at sun.reflect.GeneratedMethodAccessor66.invoke(Unknown Source) ~[?:?]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_281]
	at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_281]
	at org.apache.doris.service.FeServer.lambda$start$0(FeServer.java:60) ~[doris-fe.jar:1.2-SNAPSHOT]
	at com.sun.proxy.$Proxy34.forward(Unknown Source) ~[?:?]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3132) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3112) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:250) ~[libthrift-0.16.0.jar:0.16.0]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:03,446 WARN (thrift-server-pool-26195|332711) [StmtExecutor.handleDdlStmt():2446] 
org.apache.doris.qe.QueryStateException: errCode = 2, detailMessage = {'label':'delete_c5f7f049-37b9-4cfd-9d08-dbe44a095786', 'status':'VISIBLE', 'txnId':'235254391'}
	at org.apache.doris.load.DeleteHandler.commitJob(DeleteHandler.java:526) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.load.DeleteHandler.process(DeleteHandler.java:406) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:184) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:510) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:475) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.util.StatisticsUtil.execUpdate(StatisticsUtil.java:155) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.executeDropSql(StatisticsRepository.java:236) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatisticsByColName(StatisticsRepository.java:224) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.StatisticsRepository.dropStatistics(StatisticsRepository.java:201) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.statistics.AnalysisManager.dropStats(AnalysisManager.java:691) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.datasource.InternalCatalog.truncateTable(InternalCatalog.java:3141) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.catalog.Env.truncateTable(Env.java:5069) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.DdlExecutor.execute(DdlExecutor.java:234) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.handleDdlStmt(StmtExecutor.java:2441) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:837) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:507) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.qe.ConnectProcessor.proxyExecute(ConnectProcessor.java:784) ~[doris-fe.jar:1.2-SNAPSHOT]
	at org.apache.doris.service.FrontendServiceImpl.forward(FrontendServiceImpl.java:1096) ~[doris-fe.jar:1.2-SNAPSHOT]
	at sun.reflect.GeneratedMethodAccessor66.invoke(Unknown Source) ~[?:?]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_281]
	at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_281]
	at org.apache.doris.service.FeServer.lambda$start$0(FeServer.java:60) ~[doris-fe.jar:1.2-SNAPSHOT]
	at com.sun.proxy.$Proxy34.forward(Unknown Source) ~[?:?]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3132) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.doris.thrift.FrontendService$Processor$forward.getResult(FrontendService.java:3112) ~[fe-common-1.2-SNAPSHOT.jar:1.2-SNAPSHOT]
	at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38) ~[libthrift-0.16.0.jar:0.16.0]
	at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:250) ~[libthrift-0.16.0.jar:0.16.0]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
2025-01-06 12:40:04,812 WARN (thrift-server-pool-26539|340264) [QeProcessorImpl.reportExecStatus():205] ReportExecStatus() runtime error, query 1d4c2c7ac87c9c52-5ef9b2540b4cb882 with type LOAD does not exist
2 Answers

2025-01-06 12:40:05 413 [stream-load-upload-thread-1] [org.apache.http.impl.execchain.RetryExec] [INFO] - I/O exception (java.net.SocketException) caught when processing request to {}->http://172.31.3.70:8040: Software caused connection abort: socket write error

可以调整这个参数试试
image.png

好的,我调整一下试试