You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by fo...@apache.org on 2023/01/31 11:05:41 UTC
[hudi] 03/17: fix metatable compaction requested already exists
This is an automated email from the ASF dual-hosted git repository.
forwardxu pushed a commit to branch release-0.12.1
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 1ae6814e7f9665933d6c104294b9fe80aa897581
Author: XuQianJin-Stars <fo...@apache.com>
AuthorDate: Mon Dec 12 13:58:53 2022 +0800
fix metatable compaction requested already exists
---
.../apache/hudi/common/table/timeline/HoodieActiveTimeline.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
index 414e92e58b4..a3c7ab9e27e 100644
--- a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
+++ b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
@@ -597,7 +597,12 @@ public class HoodieActiveTimeline extends HoodieDefaultTimeline {
if (allowRedundantTransitions) {
FileIOUtils.createFileInPath(metaClient.getFs(), getInstantFileNamePath(toInstant.getFileName()), data);
} else {
- metaClient.getFs().createImmutableFileInPath(getInstantFileNamePath(toInstant.getFileName()), data);
+ if (metaClient.getMetastoreConfig().enableMetastore()
+ && metaClient.getFs().exists(getInstantFileNamePath(toInstant.getFileName()))) {
+ LOG.info(getInstantFileNamePath(toInstant.getFileName()) + " is exists!!! No need to create.");
+ } else {
+ metaClient.getFs().createImmutableFileInPath(getInstantFileNamePath(toInstant.getFileName()), data);
+ }
}
LOG.info("Create new file for toInstant ?" + getInstantFileNamePath(toInstant.getFileName()));
}