[hudi] branch master updated: [HUDI-6384] The commit action type of inflight instant for replacecommit should be replacecommit (#8987)

[danny0405]

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 bf2b712c1c4 [HUDI-6384] The commit action type of inflight instant for 
replacecommit should be replacecommit (#8987)
bf2b712c1c4 is described below

commit bf2b712c1c48981437624fa883ff25e564a25fd0
Author: Nicholas Jiang <programg...@163.com>
AuthorDate: Fri Jun 16 12:00:33 2023 +0800

    [HUDI-6384] The commit action type of inflight instant for replacecommit 
should be replacecommit (#8987)
---
 .../src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 3807ee2191b..fb496d08cab 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
@@ -223,7 +223,7 @@ public abstract class BaseHoodieWriteClient<T, I, K, O> 
extends BaseHoodieClient
     HoodieTable table = createTable(config, hadoopConf);
     HoodieCommitMetadata metadata = CommitUtils.buildMetadata(stats, 
partitionToReplaceFileIds,
         extraMetadata, operationType, config.getWriteSchema(), 
commitActionType);
-    HoodieInstant inflightInstant = new HoodieInstant(State.INFLIGHT, 
table.getMetaClient().getCommitActionType(), instantTime);
+    HoodieInstant inflightInstant = new HoodieInstant(State.INFLIGHT, 
commitActionType, instantTime);
     HeartbeatUtils.abortIfHeartbeatExpired(instantTime, table, 
heartbeatClient, config);
     this.txnManager.beginTransaction(Option.of(inflightInstant),
         lastCompletedTxnAndMetadata.isPresent() ? 
Option.of(lastCompletedTxnAndMetadata.get().getLeft()) : Option.empty());