[rocketmq] branch develop updated: [ISSUE #5070] Fix the problem of abnormal statistics under BCQ

[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 b292012ad [ISSUE #5070] Fix the problem of abnormal statistics under 
BCQ
b292012ad is described below

commit b292012ad7ead9a1e9a15522a0cb8e6e40fa165d
Author: guyinyou <36399867+guyin...@users.noreply.github.com>
AuthorDate: Wed Sep 14 21:17:57 2022 +0800

    [ISSUE #5070] Fix the problem of abnormal statistics under BCQ
---
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java           | 2 +-
 store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java 
b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index 0d8a277ce..9b9b7274b 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -926,7 +926,7 @@ public class CommitLog implements Swappable {
         PutMessageResult putMessageResult = new 
PutMessageResult(PutMessageStatus.PUT_OK, result);
 
         // Statistics
-        
storeStatsService.getSinglePutMessageTopicTimesTotal(msg.getTopic()).add(1);
+        
storeStatsService.getSinglePutMessageTopicTimesTotal(msg.getTopic()).add(result.getMsgNum());
         
storeStatsService.getSinglePutMessageTopicSizeTotal(topic).add(result.getWroteBytes());
 
         return handleDiskFlushAndHA(putMessageResult, msg, needAckNums, 
needHandleHA);
diff --git 
a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index d3e5ef06c..6f2ce3da8 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -816,7 +816,7 @@ public class DefaultMessageStore implements MessageStore {
                                 continue;
                             }
 
-                            
this.storeStatsService.getGetMessageTransferredMsgCount().add(1);
+                            
this.storeStatsService.getGetMessageTransferredMsgCount().add(cqUnit.getBatchNum());
                             getResult.addMessage(selectResult, 
cqUnit.getQueueOffset(), cqUnit.getBatchNum());
                             status = GetMessageStatus.FOUND;
                             nextPhyFileStartOffset = Long.MIN_VALUE;