diff --git a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java index 3a11e588eea90..fc4900fd7be63 100644 --- a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java +++ b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java @@ -208,11 +208,11 @@ public String showCommitPartitions(@CliOption(key = {"commit"}, help = "Commit t for (HoodieWriteStat stat : stats) { if (stat.getPrevCommit().equals(HoodieWriteStat.NULL_COMMIT)) { totalFilesAdded += 1; - totalRecordsInserted += stat.getNumWrites(); } else { totalFilesUpdated += 1; totalRecordsUpdated += stat.getNumUpdateWrites(); } + totalRecordsInserted += stat.getNumInserts(); totalBytesWritten += stat.getTotalWriteBytes(); totalWriteErrors += stat.getTotalWriteErrors(); }