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 1c20a5052378..743407495f78 100644 --- a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java +++ b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java @@ -1935,7 +1935,7 @@ public boolean commitForceCompact() { return options.get(COMMIT_FORCE_COMPACT); } - public long commitMaxTimeout() { + public long commitTimeout() { return options.get(COMMIT_MAX_TIMEOUT) == null ? Long.MAX_VALUE : options.get(COMMIT_MAX_TIMEOUT).toMillis(); diff --git a/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java b/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java index 5a49dc7f5e20..e6d63149149c 100644 --- a/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java +++ b/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java @@ -238,7 +238,7 @@ public FileStoreCommitImpl newCommit(String commitUser, List cal options.scanManifestParallelism(), callbacks, options.commitMaxRetries(), - options.commitMaxTimeout()); + options.commitTimeout()); } @Override