为了更快的定位您的问题，请提供以下信息，谢谢
【详述】Flink写入SR任务报错，reason=THRIFT_EAGAIN (timed out)
【背景】无操作
【业务影响】Flink On K8s写入SR任务报错，写入失败
【是否存算分离】是
【StarRocks版本】3.3.9-dfae8f9
【connector版本】flink-connector 1.2 或者spark-connector 1.2
【集群规模】例如：3fe（1 leader+2 follower）+5cn（fe与cn分开部署）
【机器信息】48C/256G/万兆
【联系方式】为了在解决问题过程中能及时联系到您获取一些日志信息，请补充下您的联系方式，例如：社区群16-一叶 (lixkvip@126.com)
【附件】
- 导入报错
Flink日志
2025-06-12 06:17:54
java.io.IOException: Could not perform checkpoint 32038 for operator SinkMaterializer[18] -> Sink: sink_sr_t_ds_task_instance[18] (1/1)#5.
at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1326)
at org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrierHandler.java:147)
at org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.triggerCheckpoint(SingleCheckpointBarrierHandler.java:287)
at org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.access$100(SingleCheckpointBarrierHandler.java:64)
at org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler$ControllerImpl.triggerGlobalCheckpoint(SingleCheckpointBarrierHandler.java:488)
at org.apache.flink.streaming.runtime.io.checkpointing.AbstractAlignedBarrierHandlerState.triggerGlobalCheckpoint(AbstractAlignedBarrierHandlerState.java:74)
at org.apache.flink.streaming.runtime.io.checkpointing.AbstractAlignedBarrierHandlerState.barrierReceived(AbstractAlignedBarrierHandlerState.java:66)
at org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.lambda$processBarrier$2(SingleCheckpointBarrierHandler.java:234)
at org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.markCheckpointAlignedAndTransformState(SingleCheckpointBarrierHandler.java:262)
at org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.processBarrier(SingleCheckpointBarrierHandler.java:231)
at org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate.handleEvent(CheckpointedInputGate.java:181)
at org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate.pollNext(CheckpointedInputGate.java:159)
at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:122)
at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:579)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:909)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:858)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:751)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:748)
Suppressed: java.lang.RuntimeException: com.starrocks.data.load.stream.exception.StreamLoadFailException: Transaction start failed, db: kc_tmp, table: ods_datacenter_dolphinscheduler_task_instance_si, label: flink-733579fa-2f85-494c-82cf-d3e4b59ff885, responseBody: {
“Status”: “THRIFT_RPC_ERROR”,
“Message”: “FE RPC failure, address=TNetworkAddress(hostname=xx.xx.73.44, port=9020), reason=THRIFT_EAGAIN (timed out)”
}
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.AssertNotException(StreamLoadManagerV2.java:427)
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.flush(StreamLoadManagerV2.java:355)
at com.starrocks.connector.flink.table.sink.StarRocksDynamicSinkFunctionV2.close(StarRocksDynamicSinkFunctionV2.java:251)
at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:116)
at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:163)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:125)
at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1113)
at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:255)
at org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:72)
at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127)
at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:1021)
at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940)
… 3 more
Caused by: com.starrocks.data.load.stream.exception.StreamLoadFailException: Transaction start failed, db: kc_tmp, table: ods_datacenter_dolphinscheduler_task_instance_si, label: flink-733579fa-2f85-494c-82cf-d3e4b59ff885, responseBody: {
“Status”: “THRIFT_RPC_ERROR”,
“Message”: “FE RPC failure, address=TNetworkAddress(hostname=xx.xx.73.44, port=9020), reason=THRIFT_EAGAIN (timed out)”
}
at com.starrocks.data.load.stream.TransactionStreamLoader.doBegin(TransactionStreamLoader.java:153)
at com.starrocks.data.load.stream.TransactionStreamLoader.begin(TransactionStreamLoader.java:99)
at com.starrocks.data.load.stream.DefaultStreamLoader.send(DefaultStreamLoader.java:169)
at com.starrocks.data.load.stream.v2.TransactionTableRegion.streamLoad(TransactionTableRegion.java:331)
at com.starrocks.data.load.stream.v2.TransactionTableRegion.flush(TransactionTableRegion.java:228)
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.lambda$init$0(StreamLoadManagerV2.java:179)
… 1 more
Caused by: org.apache.flink.runtime.checkpoint.CheckpointException: Could not complete snapshot 32038 for operator SinkMaterializer[18] -> Sink: sink_sr_t_ds_task_instance[18] (1/1)#5. Failure reason: Checkpoint was declined.
at org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:281)
at org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:185)
at org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:348)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.checkpointStreamOperator(RegularOperatorChain.java:228)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.buildOperatorSnapshotFutures(RegularOperatorChain.java:213)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.snapshotState(RegularOperatorChain.java:192)
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.takeSnapshotSync(SubtaskCheckpointCoordinatorImpl.java:720)
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:352)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$16(StreamTask.java:1369)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1357)
at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1314)
… 22 more
Caused by: java.lang.RuntimeException: com.starrocks.data.load.stream.exception.StreamLoadFailException: Transaction start failed, db: kc_tmp, table: ods_datacenter_dolphinscheduler_task_instance_si, label: flink-733579fa-2f85-494c-82cf-d3e4b59ff885, responseBody: {
“Status”: “THRIFT_RPC_ERROR”,
“Message”: “FE RPC failure, address=TNetworkAddress(hostname=xx.xx.73.44, port=9020), reason=THRIFT_EAGAIN (timed out)”
}
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.AssertNotException(StreamLoadManagerV2.java:427)
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.flush(StreamLoadManagerV2.java:355)
at com.starrocks.connector.flink.table.sink.StarRocksDynamicSinkFunctionV2.snapshotState(StarRocksDynamicSinkFunctionV2.java:264)
at org.apache.flink.streaming.util.functions.StreamingFunctionUtils.trySnapshotFunctionState(StreamingFunctionUtils.java:118)
at org.apache.flink.streaming.util.functions.StreamingFunctionUtils.snapshotFunctionState(StreamingFunctionUtils.java:99)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.snapshotState(AbstractUdfStreamOperator.java:89)
at org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:234)
… 33 more
[CIRCULAR REFERENCE:com.starrocks.data.load.stream.exception.StreamLoadFailException: Transaction start failed, db: kc_tmp, table: ods_datacenter_dolphinscheduler_task_instance_si, label: flink-733579fa-2f85-494c-82cf-d3e4b59ff885, responseBody: {
“Status”: “THRIFT_RPC_ERROR”,
“Message”: “FE RPC failure, address=TNetworkAddress(hostname=xx.xx.73.44, port=9020), reason=THRIFT_EAGAIN (timed out)”
}]
Fe日志报错1
2025-06-12 06:17:02.090+08:00 WARN (nioEventLoopGroup-7-14|370) [TransactionLoadAction.executeWithoutPassword():202] com.starrocks.common.UserException: No transaction found by label flink-c4b7aec4-55fd-4e62-a2b4-65277f429c3b
at com.starrocks.http.rest.transaction.TransactionWithoutChannelHandler.getTxnState(TransactionWithoutChannelHandler.java:154)
at com.starrocks.http.rest.transaction.TransactionWithoutChannelHandler.handleRollbackTransaction(TransactionWithoutChannelHandler.java:123)
at com.starrocks.http.rest.transaction.TransactionWithoutChannelHandler.handle(TransactionWithoutChannelHandler.java:80)
at com.starrocks.http.rest.TransactionLoadAction.executeTransaction(TransactionLoadAction.java:218)
at com.starrocks.http.rest.TransactionLoadAction.executeWithoutPassword(TransactionLoadAction.java:191)
at com.starrocks.http.rest.RestBaseAction.execute(RestBaseAction.java:142)
at com.starrocks.http.rest.RestBaseAction.handleRequest(RestBaseAction.java:88)
at com.starrocks.http.HttpServerHandler.channelRead(HttpServerHandler.java:107)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at io.netty.handler.codec.MessageToMessageCodec.channelRead(MessageToMessageCodec.java:111)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1357)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:868)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
FE日志报错2
2025-06-12 06:27:13.830+08:00 INFO (thrift-server-pool-2728365|26335868) [StreamLoadTask.beginTxn():313] stream load flink-703d7186-3b5e-4fbd-aa32-6092bb60a2b9 channel_id 0 begin. db: kc_finance, tbl: ods_spot_kp_account_account_pk_si, txn_id: 91870370
2025-06-12 06:27:13.830+08:00 ERROR (thrift-server-pool-2728303|26335666) [SRTThreadPoolServer$WorkerProcess.run():319] Thrift Error occurred during processing of message.
org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe (Write failed)
at org.apache.thrift.transport.TIOStreamTransport.flush(TIOStreamTransport.java:206) ~[libthrift-0.20.0.jar:0.20.0]
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:64) ~[libthrift-0.20.0.jar:0.20.0]
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:40) ~[libthrift-0.20.0.jar:0.20.0]
at com.starrocks.common.SRTThreadPoolServer$WorkerProcess.run(SRTThreadPoolServer.java:311) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:834) ~[?:?]
Caused by: java.net.SocketException: Broken pipe (Write failed)
at java.net.SocketOutputStream.socketWrite0(Native Method) ~[?:?]
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:110) ~[?:?]
at java.net.SocketOutputStream.write(SocketOutputStream.java:150) ~[?:?]
at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) ~[?:?]
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) ~[?:?]
at org.apache.thrift.transport.TIOStreamTransport.flush(TIOStreamTransport.java:201) ~[libthrift-0.20.0.jar:0.20.0]
… 6 more
2025-06-12 06:27:13.830+08:00 INFO (thrift-server-pool-2728365|26335868) [TxnStateCallbackFactory.addCallback():40] add callback of txn state : 70790963. current callback size: 972
2025-06-12 06:27:13.830+08:00 WARN (thrift-server-pool-2728303|26335666) [TIOStreamTransport.close():153] Error closing output stream.
java.net.SocketException: Socket closed
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:113) ~[?:?]
at java.net.SocketOutputStream.write(SocketOutputStream.java:150) ~[?:?]
at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) ~[?:?]
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) ~[?:?]
at java.io.FilterOutputStream.close(FilterOutputStream.java:182) ~[?:?]
at org.apache.thrift.transport.TIOStreamTransport.close(TIOStreamTransport.java:151) ~[libthrift-0.20.0.jar:0.20.0]
at org.apache.thrift.transport.TSocket.close(TSocket.java:238) ~[libthrift-0.20.0.jar:0.20.0]
at com.starrocks.common.SRTThreadPoolServer$WorkerProcess.run(SRTThreadPoolServer.java:326) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:834) ~[?:?]
2025-06-12 06:27:13.830+08:00 ERROR (thrift-server-pool-2728365|26335868) [SRTThreadPoolServer$WorkerProcess.run():319] Thrift Error occurred during processing of message.
org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe (Write failed)
at org.apache.thrift.transport.TIOStreamTransport.flush(TIOStreamTransport.java:206) ~[libthrift-0.20.0.jar:0.20.0]
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:64) ~[libthrift-0.20.0.jar:0.20.0]
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:40) ~[libthrift-0.20.0.jar:0.20.0]
FE报错
2025-06-12 06:16:53.291+08:00 WARN (thrift-server-pool-2726971|26329299) [LockManager.logSlowLockTrace():418] LockManager detects slow lock : {"owners":[{"id":26330279,"name":"starrocks-taskrun-pool-48081","type":"INTENTION_SHARED","heldFor":80537,"waitTime":0,"stack":["app//com.starrocks.connector.hive.CachingHiveMetastore.invalidatePartitionKeys(CachingHiveMetastore.java:651)","app//com.starrocks.connector.hive.CachingHiveMetastore.invalidatePartitionKeys(CachingHiveMetastore.java:652)","app//com.starrocks.connector.hive.CachingHiveMetastore.getPartitionKeysByValue(CachingHiveMetastore.java:219)","app//com.starrocks.connector.hive.HiveMetastoreOperations.getPartitionKeys(HiveMetastoreOperations.java:246)","app//com.starrocks.connector.hive.HiveMetadata.listPartitionNames(HiveMetadata.java:213)","app//com.starrocks.connector.CatalogConnectorMetadata.listPartitionNames(CatalogConnectorMetadata.java:119)","app//com.starrocks.server.MetadataMgr.listPartitionNames(MetadataMgr.java:604)","app//com.starrocks.server.MetadataMgr.listPartitionNames(MetadataMgr.java:596)","app//com.starrocks.sql.optimizer.rewrite.OptExternalPartitionPruner.initPartitionInfo(OptExternalPartitionPruner.java:328)","app//com.starrocks.sql.optimizer.rewrite.OptExternalPartitionPruner.prunePartitionsImpl(OptExternalPartitionPruner.java:129)","app//com.starrocks.sql.optimizer.rewrite.OptExternalPartitionPruner.prunePartitions(OptExternalPartitionPruner.java:85)","app//com.starrocks.sql.optimizer.rule.transformation.ExternalScanPartitionPruneRule.transform(ExternalScanPartitionPruneRule.java:72)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:80)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.rewrite(RewriteTreeTask.java:98)","app//com.starrocks.sql.optimizer.task.RewriteTreeTask.execute(RewriteTreeTask.java:58)","app//com.starrocks.sql.optimizer.task.SeriallyTaskScheduler.executeTasks(SeriallyTaskScheduler.java:65)","app//com.starrocks.sql.optimizer.Optimizer.ruleRewriteOnlyOnce(Optimizer.java:1005)","app//com.starrocks.sql.optimizer.Optimizer.logicalRuleRewrite(Optimizer.java:613)","app//com.starrocks.sql.optimizer.Optimizer.rewriteAndValidatePlan(Optimizer.java:744)","app//com.starrocks.sql.optimizer.Optimizer.optimizeByCost(Optimizer.java:247)","app//com.starrocks.sql.optimizer.Optimizer.optimize(Optimizer.java:195)","app//com.starrocks.sql.optimizer.Optimizer.optimize(Optimizer.java:171)","app//com.starrocks.sql.InsertPlanner.buildExecPlan(InsertPlanner.java:514)","app//com.starrocks.sql.InsertPlanner.plan(InsertPlanner.java:315)","app//com.starrocks.sql.StatementPlanner.planInsertStmt(StatementPlanner.java:201)","app//com.starrocks.scheduler.PartitionBasedMvRefreshProcessor.prepareRefreshPlan(PartitionBasedMvRefreshProcessor.java:515)","app//com.starrocks.scheduler.PartitionBasedMvRefreshProcessor.doRefreshMaterializedView(PartitionBasedMvRefreshProcessor.java:459)","app//com.starrocks.scheduler.PartitionBasedMvRefreshProcessor.doRefreshMaterializedViewWithRetry(PartitionBasedMvRefreshProcessor.java:368)","app//com.starrocks.scheduler.PartitionBasedMvRefreshProcessor.doMvRefresh(PartitionBasedMvRefreshProcessor.java:327)","app//com.starrocks.scheduler.PartitionBasedMvRefreshProcessor.processTaskRun(PartitionBasedMvRefreshProcessor.java:199)","app//com.starrocks.scheduler.TaskRun.executeTaskRun(TaskRun.java:270)","app//com.starrocks.scheduler.TaskRunExecutor.lambda$executeTaskRun$0(TaskRunExecutor.java:59)","app//com.starrocks.scheduler.TaskRunExecutor$Lambda$3087/0x00000008015e4840.get(Unknown Source)","java.base@11.0.2/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700)","java.base@11.0.2/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)","java.base@11.0.2/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)","java.base@11.0.2/java.lang.Thread.run(Thread.java:834)"]}],"waiter":[{"id":26331385,"name":"starrocks-taskrun-pool-48083","type":"WRITE","waitTime":41404,"stack":["java.base@11.0.2/java.lang.Thread.run(Thread.java:834)"]},{"id":26331419,"name":"thrift-server-pool-2727147","type":"INTENTION_SHARED","waitTime":36367,"stack":["java.base@11.0.2/java.lang.Thread.run(Thread.java:834)"]},{"id":173,"name":"COMPACTION_DISPATCH","type":"INTENTION_SHARED","waitTime":33539,"stack":["app//com.starrocks.common.util.Daemon.run(Daemon.java:109)"]},{"id":26331514,"name":"starrocks-taskrun-pool-48085","type":"INTENTION_SHARED","waitTime":21650,"stack":["java.base@11.0.2/java.lang.Thread.run(Thread.java:834)"]},{"id":56,"name":"MemoryUsageTracker","type":"READ","waitTime":17098,"stack":["app//com.starrocks.common.util.Daemon.run(Daemon.java:109)"]},{"id":26329299,"name":"thrift-server-pool-2726971","type":"READ","waitTime":3000,"stack":["java.base/java.lang.Thread.run(Thread.java:834)"]},{"id":26331448,"name":"starrocks-taskrun-pool-48084","type":"INTENTION_SHARED","waitTime":649,"stack":["java.base@11.0.2/java.lang.Thread.run(Thread.java:834)"]}]}
Be日志报错
W20250612 06:16:59.268312 139878157256384 thrift_rpc_helper.cpp:129] Rpc error: FE RPC failure, address=TNetworkAddress(hostname=xxx.xxx73.44, port=9020), reason=THRIFT_EAGAIN (timed out)
W20250612 06:16:59.780317 139878167742144 thrift_rpc_helper.cpp:129] Rpc error: FE RPC failure, address=TNetworkAddress(hostname=xxx.xxx73.44, port=9020), reason=THRIFT_EAGAIN (timed out)