rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinrongt...@apache.org
Subject [rocketmq] branch develop updated: [ISSUE #2477] Fix allocate algorithm in AllocateMessageQueueByMachineRoom
Date Fri, 04 Dec 2020 07:01:26 GMT
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 3cc7f09  [ISSUE #2477] Fix allocate algorithm in AllocateMessageQueueByMachineRoom
3cc7f09 is described below

commit 3cc7f095cea6583784193284e5531757839b2171
Author: qsrg <42698388+qsrg@users.noreply.github.com>
AuthorDate: Fri Dec 4 15:01:02 2020 +0800

    [ISSUE #2477] Fix allocate algorithm in AllocateMessageQueueByMachineRoom
---
 .../client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java
b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java
index 3756831..31f4e35 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java
@@ -49,7 +49,7 @@ public class AllocateMessageQueueByMachineRoom implements AllocateMessageQueueSt
         int startIndex = mod * currentIndex;
         int endIndex = startIndex + mod;
         for (int i = startIndex; i < endIndex; i++) {
-            result.add(mqAll.get(i));
+            result.add(premqAll.get(i));
         }
         if (rem > currentIndex) {
             result.add(premqAll.get(currentIndex + mod * cidAll.size()));


Mime
View raw message