[HUDI-1988] FinalizeWrite() been executed twice in AbstractHoodieWrit…

…eClient$commitstats
apache · Jun 8, 2021 · 1f85ab3 · 1f85ab3
1 parent f760ec5
commit 1f85ab3
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/...nt/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java b/...nt/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
@@ -176,8 +176,6 @@ public boolean commitStats(String instantTime, List<HoodieWriteStat> stats, Opti
     HoodieTable table = createTable(config, hadoopConf);
     HoodieCommitMetadata metadata = CommitUtils.buildMetadata(stats, partitionToReplaceFileIds,
         extraMetadata, operationType, config.getWriteSchema(), commitActionType);
-    // Finalize write
-    finalizeWrite(table, instantTime, stats);
     HeartbeatUtils.abortIfHeartbeatExpired(instantTime, table, heartbeatClient, config);
     this.txnManager.beginTransaction(Option.of(new HoodieInstant(State.INFLIGHT, table.getMetaClient().getCommitActionType(), instantTime)),
         lastCompletedTxnAndMetadata.isPresent() ? Option.of(lastCompletedTxnAndMetadata.get().getLeft()) : Option.empty());