Skip to content

Commit 811e0f5

Browse files
authored
Refactor ComputeNodeStateChangedHandler (#34935)
* Fix ClusterStateChangedHandlerTest * Refactor ComputeNodeWorkerIdChangedHandler * Refactor ComputeNodeStateChangedHandler
1 parent 9d2e0ac commit 811e0f5

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/node/ComputeNodeStateChangedHandler.java

+1-3
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
package org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.global.node;
1919

20-
import org.apache.shardingsphere.infra.instance.ComputeNodeInstanceContext;
2120
import org.apache.shardingsphere.mode.event.DataChangedEvent;
2221
import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
2322
import org.apache.shardingsphere.mode.manager.ContextManager;
@@ -50,7 +49,6 @@ public void handle(final ContextManager contextManager, final DataChangedEvent e
5049
}
5150

5251
private void handle(final ContextManager contextManager, final DataChangedEvent event, final String instanceId) {
53-
ComputeNodeInstanceContext computeNodeInstanceContext = contextManager.getComputeNodeInstanceContext();
54-
computeNodeInstanceContext.updateStatus(instanceId, event.getValue());
52+
contextManager.getComputeNodeInstanceContext().updateStatus(instanceId, event.getValue());
5553
}
5654
}

0 commit comments

Comments
 (0)