(seatunnel) branch dev updated: [Fix][Connector-V2] Fix misleading parameter name in DorisStreamLoad (#9685)

[corgy]

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

corgy pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 16618c8019 [Fix][Connector-V2] Fix misleading parameter name in 
DorisStreamLoad (#9685)
16618c8019 is described below

commit 16618c8019b3834bd8dd5bbefdc9cf4183906a7f
Author: xiaochen <598457...@qq.com>
AuthorDate: Mon Aug 11 13:42:18 2025 +0800

    [Fix][Connector-V2] Fix misleading parameter name in DorisStreamLoad (#9685)
---
 .../seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java
 
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java
index db916728f4..406e7d95ff 100644
--- 
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java
+++ 
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java
@@ -122,9 +122,9 @@ public class DorisStreamLoad implements Serializable {
         loadBatchFirstRecord = true;
     }
 
-    public void abortPreCommit(String labelSuffix, long chkID) throws 
Exception {
+    public void abortPreCommit(String labelPrefix, long chkID) throws 
Exception {
         long startChkID = chkID;
-        log.info("abort for labelSuffix {}. start chkId {}.", labelSuffix, 
chkID);
+        log.info("abort for labelPrefix {}. start chkId {}.", labelPrefix, 
chkID);
         while (true) {
             try {
                 String label = labelGenerator.generateLabel(startChkID);
@@ -176,7 +176,7 @@ public class DorisStreamLoad implements Serializable {
                 throw e;
             }
         }
-        log.info("abort for labelSuffix {} finished", labelSuffix);
+        log.info("abort for labelPrefix {} finished", labelPrefix);
     }
 
     public void writeRecord(byte[] record) throws IOException {