[HUDI-574] Fix CLI counts small file inserts as updates (#1321)
This commit is contained in:
@@ -268,11 +268,11 @@ public class CommitsCommand implements CommandMarker {
|
|||||||
for (HoodieWriteStat stat : stats) {
|
for (HoodieWriteStat stat : stats) {
|
||||||
if (stat.getPrevCommit().equals(HoodieWriteStat.NULL_COMMIT)) {
|
if (stat.getPrevCommit().equals(HoodieWriteStat.NULL_COMMIT)) {
|
||||||
totalFilesAdded += 1;
|
totalFilesAdded += 1;
|
||||||
totalRecordsInserted += stat.getNumWrites();
|
|
||||||
} else {
|
} else {
|
||||||
totalFilesUpdated += 1;
|
totalFilesUpdated += 1;
|
||||||
totalRecordsUpdated += stat.getNumUpdateWrites();
|
totalRecordsUpdated += stat.getNumUpdateWrites();
|
||||||
}
|
}
|
||||||
|
totalRecordsInserted += stat.getNumInserts();
|
||||||
totalBytesWritten += stat.getTotalWriteBytes();
|
totalBytesWritten += stat.getTotalWriteBytes();
|
||||||
totalWriteErrors += stat.getTotalWriteErrors();
|
totalWriteErrors += stat.getTotalWriteErrors();
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user