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

sunnianjun 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 3872fec5fee Refactor ContextManager (#31197)
3872fec5fee is described below

commit 3872fec5feef9496b7d59ef8d8b83acbe2f414d5
Author: Liang Zhang <[email protected]>
AuthorDate: Fri May 10 20:51:54 2024 +0800

    Refactor ContextManager (#31197)
---
 .../java/org/apache/shardingsphere/mode/manager/ContextManager.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
index edf23094e0f..ebd67de7818 100644
--- 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
+++ 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
@@ -72,7 +72,7 @@ public final class ContextManager implements AutoCloseable {
     
     private final ExecutorEngine executorEngine;
     
-    private final ClusterStateContext clusterStateContext = new 
ClusterStateContext();
+    private final ClusterStateContext clusterStateContext;
     
     public ContextManager(final MetaDataContexts metaDataContexts, final 
InstanceContext instanceContext) {
         this.metaDataContexts = new AtomicReference<>(metaDataContexts);
@@ -81,6 +81,7 @@ public final class ContextManager implements AutoCloseable {
         configurationContextManager = new 
ConfigurationContextManager(this.metaDataContexts, instanceContext);
         resourceMetaDataContextManager = new 
ResourceMetaDataContextManager(this.metaDataContexts);
         executorEngine = 
ExecutorEngine.createExecutorEngineWithSize(metaDataContexts.getMetaData().getProps().<Integer>getValue(ConfigurationPropertyKey.KERNEL_EXECUTOR_SIZE));
+        clusterStateContext = new ClusterStateContext();
     }
     
     /**
@@ -97,7 +98,7 @@ public final class ContextManager implements AutoCloseable {
      * 
      * @param metaDataContexts meta data contexts
      */
-    public synchronized void renewMetaDataContexts(final MetaDataContexts 
metaDataContexts) {
+    public void renewMetaDataContexts(final MetaDataContexts metaDataContexts) 
{
         this.metaDataContexts.set(metaDataContexts);
     }
     

Reply via email to