You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by jo...@apache.org on 2023/01/23 08:10:10 UTC
[incubator-eventmesh] branch master updated: #2731 Issue : Update EventmeshRebalanceImpl.java (#2951)
This is an automated email from the ASF dual-hosted git repository.
jonyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 3ffb00ac7 #2731 Issue : Update EventmeshRebalanceImpl.java (#2951)
3ffb00ac7 is described below
commit 3ffb00ac79dff869d681d30a94867ae41b02e7fc
Author: Preet Angad Singh Nanda <46...@users.noreply.github.com>
AuthorDate: Mon Jan 23 03:09:59 2023 -0500
#2731 Issue : Update EventmeshRebalanceImpl.java (#2951)
---
.../core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java
index 7f3d02a09..26405f8ec 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java
@@ -263,7 +263,7 @@ public class EventmeshRebalanceImpl implements EventMeshRebalanceStrategy {
}
}
for (String eventMesh : eventMeshMap.keySet()) {
- if (!localEventMeshDistributeData.keySet().contains(eventMesh)) {
+ if (!localEventMeshDistributeData.containsKey(eventMesh)) {
localEventMeshDistributeData.put(eventMesh, 0);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org