Skip to content

Commit

Permalink
Update namingserver/src/main/java/org/apache/seata/namingserver/manag…
Browse files Browse the repository at this point in the history
…er/NamingManager.java

Co-authored-by: funkye <364176773@qq.com>
  • Loading branch information
ggbocoder and funky-eyes authored Sep 4, 2024
1 parent c4e55f5 commit 46472e3
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -223,7 +223,7 @@ public void addGroup(String namespace, String clusterName, String unitName, Stri
public void notifyClusterChange(String vGroup, String namespace, String clusterName, String unitName, long term) {

Optional.ofNullable(vGroupMap.asMap().get(vGroup)).flatMap(map -> Optional.ofNullable(map.get(namespace)).flatMap(namespaceBO -> Optional.ofNullable(namespaceBO.getCluster(clusterName)))).ifPresent(clusterBO -> {
Set<String> units = clusterBO.getUnitNames();
// Set<String> units = clusterBO.getUnitNames();
// if (!CollectionUtils.isEmpty(units)) {
applicationContext.publishEvent(new ClusterChangeEvent(this, vGroup, term));
// }
Expand Down

0 comments on commit 46472e3

Please sign in to comment.