|
34 | 34 | import org.apache.amoro.config.shade.utils.ConfigShadeUtils; |
35 | 35 | import org.apache.amoro.exception.AmoroRuntimeException; |
36 | 36 | import org.apache.amoro.process.ActionCoordinator; |
| 37 | +import org.apache.amoro.process.ExecuteEngine; |
37 | 38 | import org.apache.amoro.process.ProcessFactory; |
38 | 39 | import org.apache.amoro.server.catalog.CatalogManager; |
39 | 40 | import org.apache.amoro.server.catalog.DefaultCatalogManager; |
@@ -241,14 +242,16 @@ public void startOptimizingService() throws Exception { |
241 | 242 | TableProcessFactoryManager tableProcessFactoryManager = new TableProcessFactoryManager(); |
242 | 243 | tableProcessFactoryManager.initialize(); |
243 | 244 | List<ProcessFactory> processFactories = tableProcessFactoryManager.installedPlugins(); |
| 245 | + ExecuteEngineManager executeEngineManager = new ExecuteEngineManager(); |
| 246 | + executeEngineManager.initialize(); |
| 247 | + List<ExecuteEngine> executeEngines = executeEngineManager.installedPlugins(); |
| 248 | + processFactories.forEach( |
| 249 | + c -> c.availableExecuteEngines(executeEngines)); |
244 | 250 |
|
245 | 251 | DefaultTableRuntimeFactory defaultRuntimeFactory = new DefaultTableRuntimeFactory(); |
246 | 252 | defaultRuntimeFactory.initialize(processFactories); |
247 | 253 |
|
248 | 254 | List<ActionCoordinator> actionCoordinators = defaultRuntimeFactory.supportedCoordinators(); |
249 | | - ExecuteEngineManager executeEngineManager = new ExecuteEngineManager(); |
250 | | - processFactories.forEach( |
251 | | - c -> c.availableExecuteEngines(executeEngineManager.installedPlugins())); |
252 | 255 |
|
253 | 256 | tableService = new DefaultTableService(serviceConfig, catalogManager, defaultRuntimeFactory); |
254 | 257 | processService = new ProcessService(tableService, actionCoordinators, executeEngineManager); |
|
0 commit comments