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 e84747c75 [ISSUE #2731] fixes (#2927)
e84747c75 is described below
commit e84747c757940cdd339956e850cf074f60375e2e
Author: smartPigL <[email protected]>
AuthorDate: Mon Jan 23 08:37:42 2023 +0800
[ISSUE #2731] fixes (#2927)
---
.../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 cd1987991..7f3d02a09 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
@@ -254,7 +254,7 @@ public class EventmeshRebalanceImpl implements
EventMeshRebalanceStrategy {
logger.info("before revert clientDistributionMap:{}, group:{},
purpose:{}", localEventMeshDistributeData,
group, purpose);
for (String eventMeshName : localEventMeshDistributeData.keySet())
{
- if (!eventMeshMap.keySet().contains(eventMeshName)) {
+ if (!eventMeshMap.containsKey(eventMeshName)) {
logger.warn(
"doRebalance failed,exist eventMesh not register
but exist in "
+
"distributionMap,cluster:{},grpup:{},purpose:{},eventMeshName:{}",
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
