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 00:37:50 UTC
[incubator-eventmesh] branch master updated: [ISSUE #2731] fixes (#2927)
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 <10...@users.noreply.github.com>
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: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org