Skip to content

Commit 14b2384

Browse files
committed
Refactor ContextManager
1 parent 941b1b6 commit 14b2384

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -75,10 +75,10 @@ public final class ContextManager implements AutoCloseable {
7575
public ContextManager(final MetaDataContexts metaDataContexts, final ComputeNodeInstanceContext computeNodeInstanceContext, final PersistRepository repository) {
7676
this.metaDataContexts = metaDataContexts;
7777
this.computeNodeInstanceContext = computeNodeInstanceContext;
78+
executorEngine = ExecutorEngine.createExecutorEngineWithSize(metaDataContexts.getMetaData().getProps().<Integer>getValue(ConfigurationPropertyKey.KERNEL_EXECUTOR_SIZE));
7879
metaDataContextManager = new MetaDataContextManager(metaDataContexts, computeNodeInstanceContext, repository);
7980
persistServiceFacade = new PersistServiceFacade(repository, computeNodeInstanceContext.getModeConfiguration(), metaDataContextManager);
8081
stateContext = new StateContext(persistServiceFacade.getStateService().load());
81-
executorEngine = ExecutorEngine.createExecutorEngineWithSize(metaDataContexts.getMetaData().getProps().<Integer>getValue(ConfigurationPropertyKey.KERNEL_EXECUTOR_SIZE));
8282
ContextManagerLifecycleListenerFactory.getListeners(this).forEach(each -> each.onInitialized(this));
8383
}
8484

@@ -90,7 +90,7 @@ public ContextManager(final MetaDataContexts metaDataContexts, final ComputeNode
9090
*/
9191
public ShardingSphereDatabase getDatabase(final String name) {
9292
ShardingSpherePreconditions.checkNotEmpty(name, NoDatabaseSelectedException::new);
93-
ShardingSphereMetaData metaData = getMetaDataContexts().getMetaData();
93+
ShardingSphereMetaData metaData = metaDataContexts.getMetaData();
9494
ShardingSpherePreconditions.checkState(metaData.containsDatabase(name), () -> new UnknownDatabaseException(name));
9595
return metaData.getDatabase(name);
9696
}

0 commit comments

Comments
 (0)