From 34bb1061d41dc080103a5d597b172f4d1519706e Mon Sep 17 00:00:00 2001
From: vaiowang <vaiowang@tencent.com>
Date: Wed, 3 Apr 2024 20:17:48 +0800
Subject: [PATCH] delete reosource when optimizer instance expired

---
 .../java/com/netease/arctic/server/DefaultOptimizingService.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ams/server/src/main/java/com/netease/arctic/server/DefaultOptimizingService.java b/ams/server/src/main/java/com/netease/arctic/server/DefaultOptimizingService.java
index c70675d169..9a7d17e2dd 100644
--- a/ams/server/src/main/java/com/netease/arctic/server/DefaultOptimizingService.java
+++ b/ams/server/src/main/java/com/netease/arctic/server/DefaultOptimizingService.java
@@ -548,6 +548,7 @@ public void run() {
                           .forEach(task -> retryTask(task, queue)));
           if (isExpired) {
             LOG.info("Optimizer {} has been expired, unregister it", keepingTask.getOptimizer());
+            deleteResource(keepingTask.getOptimizer().getResourceId());
             unregisterOptimizer(token);
           } else {
             LOG.debug("Optimizer {} is being touched, keep it", keepingTask.getOptimizer());