fix

JNSimba · Mar 1, 2024 · a0003db · a0003db
1 parent 4d468e2
commit a0003db
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...k-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java b/...k-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java
@@ -119,7 +119,7 @@ private void commitTransaction(CommitRequest<DorisCommittable> request) throws I
                 "commit txn {} to host {}, tolerance is {}",
                 committable.getTxnID(),
                 hostPort,
-                committable.getCommitTolerance());
+                commitTolerance);
         int retry = 0;
         while (retry <= maxRetry) {
             // get latest-url