lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-469] Fix: HoodieCommitMetadata only show first commit insert rows.

Browse Source
This commit is contained in:
Thinking
2020-01-10 16:29:51 +08:00
committed by n3nash
parent 04afac977d
commit b95367d82a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java
View File

@@ -175,7 +175,8 @@ public class HoodieCommitMetadata implements Serializable {
long totalInsertRecordsWritten = 0;
for (List<HoodieWriteStat> 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();
}
}