(amoro) branch master updated: [AMORO-3242] Fix optimizer keeper unregister npe (#3243)

[jinsongzhou]

This is an automated email from the ASF dual-hosted git repository.

jinsongzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git


The following commit(s) were added to refs/heads/master by this push:
     new 3e17628b8 [AMORO-3242] Fix optimizer keeper unregister npe (#3243)
3e17628b8 is described below

commit 3e17628b8ab304aae52d605e4610b6156a1ec007
Author: majin1102 <majin1...@gmail.com>
AuthorDate: Sat Oct 12 11:47:01 2024 +0800

    [AMORO-3242] Fix optimizer keeper unregister npe (#3243)
    
    Fix optimizer keeper unregister npe
    
    Co-authored-by: majin.nathan <majin.nat...@bytedance.com>
---
 .../main/java/org/apache/amoro/server/DefaultOptimizingService.java   | 4 +++-
 1 file changed, 3 insertions(+), 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
index 1047013bb..7069b5b49 100644
--- 
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 @@ public class DefaultOptimizingService extends 
StatedPersistentBase
     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