spotless

apache · Nov 20, 2023 · 5ec6937 · 5ec6937
1 parent e691394
commit 5ec6937
Showing 1 changed file with 8 additions and 10 deletions.
diff --git a/ams/server/src/main/java/com/netease/arctic/server/optimizing/OptimizingQueue.java b/ams/server/src/main/java/com/netease/arctic/server/optimizing/OptimizingQueue.java
@@ -357,16 +357,14 @@ private void planTasks() {
     List<TableIdentifier> plannedTables = Lists.newArrayList();
     for (TableRuntime tableRuntime : scheduledTables) {
       LOG.debug("Planning table {}", tableRuntime.getTableIdentifier());
-        AmoroTable<?> table = tableManager.loadTable(tableRuntime.getTableIdentifier());
-        OptimizingPlanner planner =
-            new OptimizingPlanner(
-                tableRuntime.refresh(table),
-                (ArcticTable) table.originalTable(),
-                getAvailableCore());
-        if (tableRuntime.isBlocked(BlockableOperation.OPTIMIZE)) {
-          LOG.info("{} optimize is blocked, continue", tableRuntime.getTableIdentifier());
-          continue;
-        }
+      AmoroTable<?> table = tableManager.loadTable(tableRuntime.getTableIdentifier());
+      OptimizingPlanner planner =
+          new OptimizingPlanner(
+              tableRuntime.refresh(table), (ArcticTable) table.originalTable(), getAvailableCore());
+      if (tableRuntime.isBlocked(BlockableOperation.OPTIMIZE)) {
+        LOG.info("{} optimize is blocked, continue", tableRuntime.getTableIdentifier());
+        continue;
+      }
       tableRuntime.beginPlanning();
       try {
         plannedTables.add(table.id());