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