This is an automated email from the ASF dual-hosted git repository.

leesf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 01c868a  [HUDI-574] Fix CLI counts small file inserts as updates 
(#1321)
01c868a is described below

commit 01c868ab86e33161b03d422c03af41f01947ea06
Author: lamber-ken <lamber...@163.com>
AuthorDate: Thu Feb 13 22:20:58 2020 +0800

    [HUDI-574] Fix CLI counts small file inserts as updates (#1321)
---
 hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 8989820..1e17c4c 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
@@ -268,11 +268,11 @@ public class CommitsCommand implements CommandMarker {
       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();
       }

Reply via email to