[rocketmq] branch develop updated: [ISSUE #3601] Fix dledger put batch msg stats bug (#3600)

[jinrongtong]

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

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new f395fa6  [ISSUE #3601] Fix dledger put batch msg stats bug (#3600)
f395fa6 is described below

commit f395fa68373c7552ad18fb522da69197bf151669
Author: coding <zanglei.z...@qq.com>
AuthorDate: Wed Dec 8 17:14:26 2021 +0800

    [ISSUE #3601] Fix dledger put batch msg stats bug (#3600)
    
    Co-authored-by: zanglei <zang...@kuaishou.com>
---
 .../main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java 
b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
index 3788673..12b8ec7 100644
--- 
a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
+++ 
b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
@@ -629,7 +629,7 @@ public class DLedgerCommitLog extends CommitLog {
             PutMessageResult putMessageResult = new 
PutMessageResult(putMessageStatus, appendResult);
             if (putMessageStatus == PutMessageStatus.PUT_OK) {
                 // Statistics
-                
storeStatsService.getSinglePutMessageTopicTimesTotal(messageExtBatch.getTopic()).add(1);
+                
storeStatsService.getSinglePutMessageTopicTimesTotal(messageExtBatch.getTopic()).add(appendResult.getMsgNum());
                 
storeStatsService.getSinglePutMessageTopicSizeTotal(messageExtBatch.getTopic()).add(appendResult.getWroteBytes());
             }
             return putMessageResult;