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()); } }