[AMORO-3242] Fix optimizer keeper unregister npe (#3243)

Fix optimizer keeper unregister npe Co-authored-by: majin.nathan <[email protected]>
apache · Oct 12, 2024 · 3e17628 · 3e17628
1 parent 119d661
commit 3e17628
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -164,7 +164,9 @@ private void unregisterOptimizer(String token) {
     doAs(OptimizerMapper.class, mapper -> mapper.deleteOptimizer(token));
     OptimizingQueue optimizingQueue = optimizingQueueByToken.remove(token);
     OptimizerInstance optimizer = authOptimizers.remove(token);
-    optimizingQueue.removeOptimizer(optimizer);
+    if (optimizingQueue != null) {
+      optimizingQueue.removeOptimizer(optimizer);
+    }
   }
 
   @Override