[AMORO-3346] Extract the implementation of OptimizerManager

apache · Feb 11, 2025 · d593eeb · d593eeb
1 parent 111b469
commit d593eeb
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/DefaultOptimizingService.java b/amoro-ams/src/main/java/org/apache/amoro/server/DefaultOptimizingService.java
@@ -72,8 +72,10 @@ public class DefaultOptimizingService extends StatedPersistentBase
 
   public DefaultOptimizingService(
       Configurations serviceConfig, OptimizerManager optimizerManager, TableService tableService) {
-    this.optimizerTouchTimeout = serviceConfig.get(AmoroManagementConf.OPTIMIZER_HB_TIMEOUT).toMillis();
-    this.pollingTimeout = serviceConfig.get(AmoroManagementConf.OPTIMIZER_POLLING_TIMEOUT).toMillis();
+    this.optimizerTouchTimeout =
+        serviceConfig.get(AmoroManagementConf.OPTIMIZER_HB_TIMEOUT).toMillis();
+    this.pollingTimeout =
+        serviceConfig.get(AmoroManagementConf.OPTIMIZER_POLLING_TIMEOUT).toMillis();
     this.tableService = tableService;
     this.optimizerManager = optimizerManager;
   }

diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/resource/DefaultOptimizerManager.java b/amoro-ams/src/main/java/org/apache/amoro/server/resource/DefaultOptimizerManager.java
@@ -83,8 +83,10 @@ public class DefaultOptimizerManager extends PersistentBase
 
   public DefaultOptimizerManager(
       Configurations serviceConfig, CatalogManager catalogManager, TableManager tableManager) {
-    this.optimizerTouchTimeout = serviceConfig.get(AmoroManagementConf.OPTIMIZER_HB_TIMEOUT).toMillis();
-    this.taskAckTimeout = serviceConfig.get(AmoroManagementConf.OPTIMIZER_TASK_ACK_TIMEOUT).toMillis();
+    this.optimizerTouchTimeout =
+        serviceConfig.get(AmoroManagementConf.OPTIMIZER_HB_TIMEOUT).toMillis();
+    this.taskAckTimeout =
+        serviceConfig.get(AmoroManagementConf.OPTIMIZER_TASK_ACK_TIMEOUT).toMillis();
     this.maxPlanningParallelism =
         serviceConfig.getInteger(AmoroManagementConf.OPTIMIZER_MAX_PLANNING_PARALLELISM);
     this.tableManager = tableManager;