You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by ti...@apache.org on 2020/01/15 02:10:54 UTC
[incubator-tubemq] branch master updated: [TUBEMQ-20] Correct
DefaultLoadBalancer#balance parameter
This is an automated email from the ASF dual-hosted git repository.
tison pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
The following commit(s) were added to refs/heads/master by this push:
new ab3c7ae [TUBEMQ-20] Correct DefaultLoadBalancer#balance parameter
ab3c7ae is described below
commit ab3c7ae57179703cfa1b0d41e61724b8f7b3de30
Author: Tboy <gu...@immomo.com>
AuthorDate: Wed Jan 15 10:10:47 2020 +0800
[TUBEMQ-20] Correct DefaultLoadBalancer#balance parameter
Correct DefaultLoadBalancer#balance rejGroupClientINfoMap -> rejGroupClientInfoMap
This closes #11 .
---
.../com/tencent/tubemq/server/master/balance/DefaultLoadBalancer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tubemq-server/src/main/java/com/tencent/tubemq/server/master/balance/DefaultLoadBalancer.java b/tubemq-server/src/main/java/com/tencent/tubemq/server/master/balance/DefaultLoadBalancer.java
index 1d1f592..c0253c0 100644
--- a/tubemq-server/src/main/java/com/tencent/tubemq/server/master/balance/DefaultLoadBalancer.java
+++ b/tubemq-server/src/main/java/com/tencent/tubemq/server/master/balance/DefaultLoadBalancer.java
@@ -247,7 +247,7 @@ public class DefaultLoadBalancer implements LoadBalancer {
TopicPSInfoManager topicPSInfoManager,
List<String> groupSet,
Map<String, Map<String, Map<String, Partition>>> oldClusterState,
- Map<String, RebProcessInfo> rejGroupClientINfoMap) {
+ Map<String, RebProcessInfo> rejGroupClientInfoMap) {
// according to group
for (String group : groupSet) {
ConsumerBandInfo consumerBandInfo = consumerHolder.getConsumerBandInfo(group);
@@ -257,7 +257,7 @@ public class DefaultLoadBalancer implements LoadBalancer {
// filter consumer which don't need to handle
List<ConsumerInfo> consumerList = new ArrayList<ConsumerInfo>();
List<ConsumerInfo> consumerList1 = consumerBandInfo.getConsumerInfoList();
- RebProcessInfo rebProcessInfo = rejGroupClientINfoMap.get(group);
+ RebProcessInfo rebProcessInfo = rejGroupClientInfoMap.get(group);
if (rebProcessInfo != null) {
for (ConsumerInfo consumerInfo : consumerList1) {
if (rebProcessInfo.needProcessList.contains(consumerInfo.getConsumerId())