diff --git a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/TransactionTableRegion.java b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/TransactionTableRegion.java
index fa6ce88d..dd395e00 100644
--- a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/TransactionTableRegion.java
+++ b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/TransactionTableRegion.java
@@ -125,6 +125,10 @@ public LabelGenerator getLabelGenerator() {
 
     @Override
     public void setLabel(String label) {
+        // Reuse the same label to avoid duplicate load if retry happens
+        if (numRetries > 0 && label != null) {
+            return;
+        }
         this.label = label;
     }