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