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