From a0003db7569b80a37a66955b4b63aa3f5ba3edc7 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Fri, 1 Mar 2024 17:22:00 +0800 Subject: [PATCH] fix --- .../org/apache/doris/flink/sink/committer/DorisCommitter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java index 56bed7df3..53f96f464 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java @@ -119,7 +119,7 @@ private void commitTransaction(CommitRequest request) throws I "commit txn {} to host {}, tolerance is {}", committable.getTxnID(), hostPort, - committable.getCommitTolerance()); + commitTolerance); int retry = 0; while (retry <= maxRetry) { // get latest-url