(shardingsphere) branch master updated: Refactor ClusterStateDispatchEventBuilder (#32898)

[chengzhang]

This is an automated email from the ASF dual-hosted git repository.

chengzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 56ff2df5f78 Refactor ClusterStateDispatchEventBuilder (#32898)
56ff2df5f78 is described below

commit 56ff2df5f786ad3cb07bc07372a2a32ce47b3d88
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Mon Sep 16 10:15:56 2024 +0800

    Refactor ClusterStateDispatchEventBuilder (#32898)
---
 .../cluster/event/builder/ClusterStateDispatchEventBuilder.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java
index 01c16543406..10296ed2bd1 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java
@@ -40,12 +40,12 @@ public final class ClusterStateDispatchEventBuilder 
implements DispatchEventBuil
     
     @Override
     public Collection<Type> getSubscribedTypes() {
-        return Arrays.asList(Type.ADDED, Type.UPDATED, Type.DELETED);
+        return Arrays.asList(Type.ADDED, Type.UPDATED);
     }
     
     @Override
     public Optional<DispatchEvent> build(final DataChangedEvent event) {
-        return Type.DELETED == event.getType() || 
!event.getKey().equals(ComputeNode.getClusterStateNodePath()) ? 
Optional.empty() : Optional.of(new ClusterStateEvent(getClusterState(event)));
+        return event.getKey().equals(ComputeNode.getClusterStateNodePath()) ? 
Optional.of(new ClusterStateEvent(getClusterState(event))) : Optional.empty();
     }
     
     private ClusterState getClusterState(final DataChangedEvent event) {