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

zhangliang 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 811e0f5277b Refactor ComputeNodeStateChangedHandler (#34935)
811e0f5277b is described below

commit 811e0f5277b08675457042851add3e3afa1771b0
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sat Mar 8 06:44:38 2025 +0800

    Refactor ComputeNodeStateChangedHandler (#34935)
    
    * Fix ClusterStateChangedHandlerTest
    
    * Refactor ComputeNodeWorkerIdChangedHandler
    
    * Refactor ComputeNodeStateChangedHandler
---
 .../dispatch/handler/global/node/ComputeNodeStateChangedHandler.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/node/ComputeNodeStateChangedHandler.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/node/ComputeNodeStateChangedHandler.java
index e14ec0b14d3..cbd39e426c8 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/node/ComputeNodeStateChangedHandler.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/node/ComputeNodeStateChangedHandler.java
@@ -17,7 +17,6 @@
 
 package 
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.global.node;
 
-import org.apache.shardingsphere.infra.instance.ComputeNodeInstanceContext;
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.manager.ContextManager;
@@ -50,7 +49,6 @@ public final class ComputeNodeStateChangedHandler implements 
GlobalDataChangedEv
     }
     
     private void handle(final ContextManager contextManager, final 
DataChangedEvent event, final String instanceId) {
-        ComputeNodeInstanceContext computeNodeInstanceContext = 
contextManager.getComputeNodeInstanceContext();
-        computeNodeInstanceContext.updateStatus(instanceId, event.getValue());
+        
contextManager.getComputeNodeInstanceContext().updateStatus(instanceId, 
event.getValue());
     }
 }

Reply via email to