Add ClusterInstanceRegistry

apache · Dec 17, 2024 · 8c612f8 · 8c612f8
1 parent 08956c1
commit 8c612f8
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/...on/src/main/java/org/apache/shardingsphere/infra/instance/ComputeNodeInstanceContext.java b/...on/src/main/java/org/apache/shardingsphere/infra/instance/ComputeNodeInstanceContext.java
@@ -45,18 +45,20 @@ public final class ComputeNodeInstanceContext {
 
     private final EventBusContext eventBusContext;
 
-    private final ClusterInstanceRegistry clusterInstanceRegistry;
-
     @Getter(AccessLevel.NONE)
-    private final AtomicReference<WorkerIdGenerator> workerIdGenerator = new AtomicReference<>();
+    private final AtomicReference<WorkerIdGenerator> workerIdGenerator;
 
     @Getter(AccessLevel.NONE)
-    private final AtomicReference<LockContext<?>> lockContext = new AtomicReference<>();
+    private final AtomicReference<LockContext<?>> lockContext;
+
+    private final ClusterInstanceRegistry clusterInstanceRegistry;
 
     public ComputeNodeInstanceContext(final ComputeNodeInstance instance, final ModeConfiguration modeConfiguration, final EventBusContext eventBusContext) {
         this.instance = instance;
         this.modeConfiguration = modeConfiguration;
         this.eventBusContext = eventBusContext;
+        workerIdGenerator = new AtomicReference<>();
+        lockContext = new AtomicReference<>();
         clusterInstanceRegistry = new ClusterInstanceRegistry();
     }