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 <[email protected]>
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()));
