From d3711a26415703c3db412ad3102856ce15459cde Mon Sep 17 00:00:00 2001 From: liujianhui Date: Sun, 12 Apr 2020 22:11:38 +0800 Subject: [PATCH] [HUDI-525] lack of insert info in delta_commit inflight [HUDI-525] lack of insert info in delta_commit inflight [HUDI-525] lack of insert info in delta_commit inflight [HUDI-525] lack of insert info in delta_commit inflight [HUDI-525] lack of insert info in delta_commit inflight [HUDI-525] lack of insert info in delta_commit inflight HUDI-525 --- .../hudi/table/action/commit/BaseCommitActionExecutor.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/hudi-client/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java b/hudi-client/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java index a8f4341f7..5408d44cf 100644 --- a/hudi-client/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java +++ b/hudi-client/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java @@ -116,6 +116,12 @@ public abstract class BaseCommitActionExecutor, HoodieCommitMetadata metadata = new HoodieCommitMetadata(); profile.getPartitionPaths().forEach(path -> { WorkloadStat partitionStat = profile.getWorkloadStat(path.toString()); + HoodieWriteStat insertStat = new HoodieWriteStat(); + insertStat.setNumInserts(partitionStat.getNumInserts()); + insertStat.setFileId(""); + insertStat.setPrevCommit(HoodieWriteStat.NULL_COMMIT); + metadata.addWriteStat(path.toString(), insertStat); + partitionStat.getUpdateLocationToCount().forEach((key, value) -> { HoodieWriteStat writeStat = new HoodieWriteStat(); writeStat.setFileId(key);