为了更快的定位您的问题，请提供以下信息，谢谢
【详述】使用kafka-connector导入数据发生label异常
【背景】在最新的kafka-connector的基础上改造适配canal发给kafka的消息格式，之后通过connector把消息传递给starrocks
【业务影响】
【是否存算分离】否
【StarRocks版本】例如：3.5最新的版本
【集群规模】例如：3fe（1 follower+2observer）+5be（fe与be混部）
【机器信息】CPU虚拟核/内存/网卡，例如：48C/64G/万兆
【表模型】主键模型
【导入或者导出方式】Kafka-connector
【联系方式】1119094956@qq.com
【附件】
[2025-09-22 10:43:41,702] ERROR [starrock_eacp_contract|task-0] Transaction rollback failed, db: eacp_contract, table: contract_deposit, label : -87cf7a62-4b98-42c2-bde9-17cafca84b71, message: class com.starrocks.common.StarRocksException: No transaction found by label -87cf7a62-4b98-42c2-bde9-17cafca84b71 (com.starrocks.data.load.stream.TransactionStreamLoader:351)
[2025-09-22 10:43:41,702] INFO [starrock_eacp_contract|task-0] Transaction rollback, label : -87cf7a62-4b98-42c2-bde9-17cafca84b71 (com.starrocks.data.load.stream.TransactionStreamLoader:318)
[2025-09-22 10:43:41,703] INFO [starrock_eacp_contract|task-0] Stream load completed, label : null, database : eacp_contract, table : out_contract_progress_confirmation, body : {
“Status”: “FAILED”,
“Message”: “class com.starrocks.common.StarRocksException: Empty label.”
} (com.starrocks.data.load.stream.DefaultStreamLoader:316)
[2025-09-22 10:43:41,703] ERROR [starrock_eacp_contract|task-0] Exception happens when sending data, thread: I/O client dispatch - 61d4558b-314a-47c8-a3bb-7124d2c07621 (com.starrocks.data.load.stream.DefaultStreamLoader:360)
com.starrocks.data.load.stream.exception.StreamLoadFailException: Stream load failed because of error, db: eacp_contract, table: out_contract_progress_confirmation, label: null,
responseBody: {
“Status”: “FAILED”,
“Message”: “class com.starrocks.common.StarRocksException: Empty label.”
}
errorLog: null
at com.starrocks.data.load.stream.DefaultStreamLoader.sendToSR(DefaultStreamLoader.java:349)
at com.starrocks.data.load.stream.DefaultStreamLoader.lambda$send$3(DefaultStreamLoader.java:176)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[2025-09-22 10:43:41,703] ERROR [starrock_eacp_contract|task-0] Failed to flush data for db: eacp_contract, table: out_contract_progress_confirmation after 0 times retry, the last exception is (com.starrocks.data.load.stream.v2.TransactionTableRegion:331)
com.starrocks.data.load.stream.exception.StreamLoadFailException: Stream load failed because of error, db: eacp_contract, table: out_contract_progress_confirmation, label: null,
responseBody: {
“Status”: “FAILED”,
“Message”: “class com.starrocks.common.StarRocksException: Empty label.”
}
errorLog: null
at com.starrocks.data.load.stream.DefaultStreamLoader.sendToSR(DefaultStreamLoader.java:349)
at com.starrocks.data.load.stream.DefaultStreamLoader.lambda$send$3(DefaultStreamLoader.java:176)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[2025-09-22 10:43:41,703] ERROR [starrock_eacp_contract|task-0] Stream load failed (com.starrocks.data.load.stream.v2.StreamLoadManagerV2:341)
com.starrocks.data.load.stream.exception.StreamLoadFailException: Stream load failed because of error, db: eacp_contract, table: out_contract_progress_confirmation, label: null,
responseBody: {
“Status”: “FAILED”,
“Message”: “class com.starrocks.common.StarRocksException: Empty label.”
}
errorLog: null
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.AssertNotException(StreamLoadManagerV2.java:428)
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.write(StreamLoadManagerV2.java:253)
at com.starrocks.connector.kafka.StarRocksSinkTask.put(StarRocksSinkTask.java:565)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:606)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:345)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:247)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:216)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
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)
at java.lang.Thread.run(Thread.java:748)
Caused by: com.starrocks.data.load.stream.exception.StreamLoadFailException: Stream load failed because of error, db: eacp_contract, table: out_contract_progress_confirmation, label: null,
responseBody: {
“Status”: “FAILED”,
“Message”: “class com.starrocks.common.StarRocksException: Empty label.”
}
Caused by: com.starrocks.data.load.stream.exception.StreamLoadFailException: Stream load failed because of error, db: eacp_contract, table: out_contract_progress_confirmation, label: null,
out_contract_progress_confirmation这个表不是业务表，不知道为什么会有？