@@ -75,10 +75,10 @@ public final class ContextManager implements AutoCloseable {
75
75
public ContextManager (final MetaDataContexts metaDataContexts , final ComputeNodeInstanceContext computeNodeInstanceContext , final PersistRepository repository ) {
76
76
this .metaDataContexts = metaDataContexts ;
77
77
this .computeNodeInstanceContext = computeNodeInstanceContext ;
78
+ executorEngine = ExecutorEngine .createExecutorEngineWithSize (metaDataContexts .getMetaData ().getProps ().<Integer >getValue (ConfigurationPropertyKey .KERNEL_EXECUTOR_SIZE ));
78
79
metaDataContextManager = new MetaDataContextManager (metaDataContexts , computeNodeInstanceContext , repository );
79
80
persistServiceFacade = new PersistServiceFacade (repository , computeNodeInstanceContext .getModeConfiguration (), metaDataContextManager );
80
81
stateContext = new StateContext (persistServiceFacade .getStateService ().load ());
81
- executorEngine = ExecutorEngine .createExecutorEngineWithSize (metaDataContexts .getMetaData ().getProps ().<Integer >getValue (ConfigurationPropertyKey .KERNEL_EXECUTOR_SIZE ));
82
82
ContextManagerLifecycleListenerFactory .getListeners (this ).forEach (each -> each .onInitialized (this ));
83
83
}
84
84
@@ -90,7 +90,7 @@ public ContextManager(final MetaDataContexts metaDataContexts, final ComputeNode
90
90
*/
91
91
public ShardingSphereDatabase getDatabase (final String name ) {
92
92
ShardingSpherePreconditions .checkNotEmpty (name , NoDatabaseSelectedException ::new );
93
- ShardingSphereMetaData metaData = getMetaDataContexts () .getMetaData ();
93
+ ShardingSphereMetaData metaData = metaDataContexts .getMetaData ();
94
94
ShardingSpherePreconditions .checkState (metaData .containsDatabase (name ), () -> new UnknownDatabaseException (name ));
95
95
return metaData .getDatabase (name );
96
96
}
0 commit comments