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);