From b95367d82a4e0c31a526cf8b292388355847e274 Mon Sep 17 00:00:00 2001 From: Thinking <744417972@qq.com> Date: Fri, 10 Jan 2020 16:29:51 +0800 Subject: [PATCH] [HUDI-469] Fix: HoodieCommitMetadata only show first commit insert rows. --- .../org/apache/hudi/common/model/HoodieCommitMetadata.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java b/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java index 475f75ccc..fcca3203b 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java @@ -175,7 +175,8 @@ public class HoodieCommitMetadata implements Serializable { long totalInsertRecordsWritten = 0; for (List stats : partitionToWriteStats.values()) { for (HoodieWriteStat stat : stats) { - if (stat.getPrevCommit() != null && stat.getPrevCommit().equalsIgnoreCase("null")) { + // determine insert rows in every file + if (stat.getPrevCommit() != null) { totalInsertRecordsWritten += stat.getNumInserts(); } }