[doris-flink-connector] branch master updated: [improve] add ckptid in label when 2pc false (#207)

[zykkk]

This is an automated email from the ASF dual-hosted git repository.

zykkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 84b9bda  [improve] add ckptid in label when 2pc false (#207)
84b9bda is described below

commit 84b9bdac2b1c6231796daf714030cfc86ff3bca5
Author: wudi <676366...@qq.com>
AuthorDate: Fri Oct 13 11:56:35 2023 +0800

    [improve] add ckptid in label when 2pc false (#207)
    
    Currently, when 2pc is closed, the label will only splice the uuid without 
adding the ckid, which is inconvenient to locate the problem.
---
 .../main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 35edae9..235b553 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 class LabelGenerator {
     }
 
     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() {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org