This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 7103e50db7f [HUDI-9039] Run do init table transaction only when
required (#12847)
7103e50db7f is described below
commit 7103e50db7f6117d609c8bc6bac2fc777329a80a
Author: Leon Lin <[email protected]>
AuthorDate: Tue Feb 18 19:08:40 2025 -0800
[HUDI-9039] Run do init table transaction only when required (#12847)
Co-authored-by: Leon Lin <[email protected]>
---
.../src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java
index e46ff8bbc8e..4b3f90c43f3 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java
@@ -1299,6 +1299,10 @@ public abstract class BaseHoodieWriteClient<T, I, K, O>
extends BaseHoodieClient
ownerInstant =
Option.of(metaClient.createNewInstant(HoodieInstant.State.INFLIGHT,
CommitUtils.getCommitActionType(operationType,
metaClient.getTableType()), instantTime.get()));
}
+ boolean requiresInitTable = needsUpgradeOrDowngrade(metaClient) ||
config.isMetadataTableEnabled();
+ if (!requiresInitTable) {
+ return;
+ }
executeUsingTxnManager(ownerInstant, () -> {
tryUpgrade(metaClient, instantTime);
// TODO: this also does MT table management..