This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a commit to branch branch-0.x
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/branch-0.x by this push:
new 67ae2458ae4f [HUDI-9039] Run do init table transaction only when
required (#12847) (#17856)
67ae2458ae4f is described below
commit 67ae2458ae4f0721240d148aae17f8bd89a3552d
Author: Lin Liu <[email protected]>
AuthorDate: Thu Feb 5 01:22:55 2026 -0800
[HUDI-9039] Run do init table transaction only when required (#12847)
(#17856)
Co-authored-by: Leon Lin <[email protected]>
Co-authored-by: Leon Lin <[email protected]>
---
.../apache/hudi/client/BaseHoodieWriteClient.java | 21 +++++++++++++++++++--
1 file changed, 19 insertions(+), 2 deletions(-)
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 d4f41d4c9fd3..e1ad403c783d 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
@@ -40,6 +40,7 @@ import org.apache.hudi.common.model.ActionType;
import org.apache.hudi.common.model.HoodieCommitMetadata;
import org.apache.hudi.common.model.HoodieFailedWritesCleaningPolicy;
import org.apache.hudi.common.model.HoodieKey;
+import org.apache.hudi.common.model.HoodieRecordLocation;
import org.apache.hudi.common.model.HoodieWriteStat;
import org.apache.hudi.common.model.TableServiceType;
import org.apache.hudi.common.model.WriteOperationType;
@@ -1249,15 +1250,31 @@ public abstract class BaseHoodieWriteClient<T, I, K, O>
extends BaseHoodieClient
if (instantTime.isPresent()) {
ownerInstant = Option.of(new HoodieInstant(true,
CommitUtils.getCommitActionType(operationType, metaClient.getTableType()),
instantTime.get()));
}
- this.txnManager.beginTransaction(ownerInstant, Option.empty());
- try {
+ boolean requiresInitTable = needsUpgradeOrDowngrade(metaClient) ||
config.isMetadataTableEnabled();
+ if (!requiresInitTable) {
+ return;
+ }
+ executeUsingTxnManager(ownerInstant, () -> {
tryUpgrade(metaClient, instantTime);
+ // TODO: this also does MT table management..
initMetadataTable(instantTime, metaClient);
+ });
+ }
+
+ private void executeUsingTxnManager(Option<HoodieInstant> ownerInstant,
Runnable r) {
+ this.txnManager.beginTransaction(ownerInstant, Option.empty());
+ try {
+ r.run();
} finally {
this.txnManager.endTransaction(ownerInstant);
}
}
+ private boolean needsUpgradeOrDowngrade(HoodieTableMetaClient metaClient) {
+ UpgradeDowngrade upgradeDowngrade = new UpgradeDowngrade(metaClient,
config, context, upgradeDowngradeHelper);
+ return
upgradeDowngrade.needsUpgradeOrDowngrade(HoodieTableVersion.current());
+ }
+
/**
* Bootstrap the metadata table.
*
