Skip to content

Commit

Permalink
1
Browse files Browse the repository at this point in the history
  • Loading branch information
xuyu committed Dec 10, 2024
1 parent 3a0b504 commit 5aaa389
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -527,7 +527,7 @@ public class CoreOptions implements Serializable {
.defaultValue(false)
.withDescription("Whether to force a compaction before commit.");

public static final ConfigOption<Duration> COMMIT_MAX_TIMEOUT =
public static final ConfigOption<Duration> COMMIT_TIMEOUT =
key("commit.timeout")
.durationType()
.noDefaultValue()
Expand Down Expand Up @@ -1936,9 +1936,9 @@ public boolean commitForceCompact() {
}

public long commitTimeout() {
return options.get(COMMIT_MAX_TIMEOUT) == null
return options.get(COMMIT_TIMEOUT) == null
? Long.MAX_VALUE
: options.get(COMMIT_MAX_TIMEOUT).toMillis();
: options.get(COMMIT_TIMEOUT).toMillis();
}

public int commitMaxRetries() {
Expand Down

0 comments on commit 5aaa389

Please sign in to comment.