[rocketmq] branch develop updated: Fix the issue of inaccurate statistics of the slave node under BCQ (#5239)

[duhengforever]

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

duhengforever 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 d0b28117d Fix the issue of inaccurate statistics of the slave node 
under BCQ (#5239)
d0b28117d is described below

commit d0b28117dc0c527f5abcde75cb6a8db0667e5404
Author: rongtong <jinrongto...@163.com>
AuthorDate: Fri Oct 7 08:18:38 2022 +0800

    Fix the issue of inaccurate statistics of the slave node under BCQ (#5239)
---
 store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 f0546321f..77914763b 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -2507,7 +2507,7 @@ public class DefaultMessageStore implements MessageStore {
                                 if 
(!DefaultMessageStore.this.getMessageStoreConfig().isDuplicationEnable() &&
                                     
DefaultMessageStore.this.getMessageStoreConfig().getBrokerRole() == 
BrokerRole.SLAVE) {
                                     DefaultMessageStore.this.storeStatsService
-                                        
.getSinglePutMessageTopicTimesTotal(dispatchRequest.getTopic()).add(1);
+                                        
.getSinglePutMessageTopicTimesTotal(dispatchRequest.getTopic()).add(dispatchRequest.getBatchSize());
                                     DefaultMessageStore.this.storeStatsService
                                         
.getSinglePutMessageTopicSizeTotal(dispatchRequest.getTopic())
                                         .add(dispatchRequest.getMsgSize());