为了更快的定位您的问题，请提供以下信息，谢谢
【详述】Flink任务运行一天后，突然出现has no node的错误，用的flink starrocks connetor
【背景】无
【业务影响】 数据无法导入
【是否存算分离】
【StarRocks版本】例如：3.2.8
【集群规模】例如：3fe+10BE
【机器信息】
【联系方式】
相关敏感信息我用xxx和test01来表示了，主要的异常报错就是label has no node
Failed to flush when closing
java.lang.RuntimeException: com.starrocks.data.load.stream.exception.StreamLoadFailException: Stream load failed because of error, db: dwd, table:test01, label: starrocks_dwd_rsk_fpt_rule_di_label_prod_03-test01-16-1370,
responseBody: {
“Status”: “FAILED”,
“Message”: “class com.starrocks.common.UserException: Transaction with op[load] and label[starrocks_xxx_label_prod_03-test01-16-1370] has no node.”
}
errorLog: null
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:114)
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:1025)
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:943)
at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:917)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)
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: com.starrocks.data.load.stream.exception.StreamLoadFailException: Stream load failed because of error, db: dwd, table: test01, label: starrocks_xxx_label_prod_03-test01-16-1370,
responseBody: {
“Status”: “FAILED”,
“Message”: “class com.starrocks.common.UserException: Transaction with op[load] and label[starrocks_xxx_label_prod_03-test01-16-1370] has no node.”
}