From 5aaa389f097622a163afef15126cd1e4a3c69e4e Mon Sep 17 00:00:00 2001 From: xuyu <11161569@vivo.com> Date: Tue, 10 Dec 2024 12:15:22 +0800 Subject: [PATCH] 1 --- .../src/main/java/org/apache/paimon/CoreOptions.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java index 743407495f78..c567e6266bfa 100644 --- a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java +++ b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java @@ -527,7 +527,7 @@ public class CoreOptions implements Serializable { .defaultValue(false) .withDescription("Whether to force a compaction before commit."); - public static final ConfigOption COMMIT_MAX_TIMEOUT = + public static final ConfigOption COMMIT_TIMEOUT = key("commit.timeout") .durationType() .noDefaultValue() @@ -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() {