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
<[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
