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() {