From 3a0b504ec17368c363e90da2abfd9f0e8283e27f Mon Sep 17 00:00:00 2001 From: xuyu <11161569@vivo.com> Date: Tue, 10 Dec 2024 12:11:06 +0800 Subject: [PATCH] fix mills --- paimon-common/src/main/java/org/apache/paimon/CoreOptions.java | 2 +- .../src/main/java/org/apache/paimon/AbstractFileStore.java | 2 +- 2 files changed, 2 insertions(+), 2 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 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