From 1f85ab34292c5d57503581f120f04b0472beed1d Mon Sep 17 00:00:00 2001 From: "337361684@qq.com" <337361684@qq.com> Date: Tue, 8 Jun 2021 18:34:25 +0800 Subject: [PATCH] [HUDI-1988] FinalizeWrite() been executed twice in AbstractHoodieWriteClient$commitstats --- .../java/org/apache/hudi/client/AbstractHoodieWriteClient.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java index 39c1bc0e5fec..b0b8d55d52aa 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java @@ -176,8 +176,6 @@ public boolean commitStats(String instantTime, List 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());