From 4d468e2a663e9bada3332b0b8a51e09d314768db Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Fri, 1 Mar 2024 17:12:35 +0800 Subject: [PATCH] fix --- .../java/org/apache/doris/flink/cfg/DorisExecutionOptions.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java index a517789b0..9bed35218 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java @@ -329,8 +329,9 @@ public Builder setWriteMode(WriteMode writeMode) { return this; } - public void setCommitTolerance(CommitTolerance commitTolerance) { + public Builder setCommitTolerance(CommitTolerance commitTolerance) { this.commitTolerance = commitTolerance; + return this; } public DorisExecutionOptions build() {