diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java index 35edae9e2..235b553d0 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java @@ -31,7 +31,8 @@ public LabelGenerator(String labelPrefix, boolean enable2PC) { } public String generateLabel(long chkId) { - return enable2PC ? labelPrefix + "_" + chkId : labelPrefix + "_" + UUID.randomUUID(); + String label = labelPrefix + "_" + chkId; + return enable2PC ? label : label + "_" + UUID.randomUUID(); } public String generateBatchLabel() {