From c6c4021930674d4c8e61289804654509bb2e13dc Mon Sep 17 00:00:00 2001
From: lanyuanxiaoyao <lanyuanxiaoyao@gmail.com>
Date: Mon, 29 Jan 2024 10:42:25 +0800
Subject: [PATCH] =?UTF-8?q?feat(forest):=20=E5=8E=8B=E7=BC=A9=E8=B0=83?=
 =?UTF-8?q?=E5=BA=A6=E5=A2=9E=E5=8A=A0=E4=B8=8D=E5=88=A0=E9=99=A4=E8=A1=A8?=
 =?UTF-8?q?=E5=81=9C=E6=AD=A2=E5=85=A8=E9=83=A8=E5=8E=8B=E7=BC=A9=E7=9A=84?=
 =?UTF-8?q?=E5=8F=82=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/forest/service/launcher/LauncherService.java    | 3 +++
 .../service/forest/service/launcher/LaunchersService.java   | 6 ++++++
 2 files changed, 9 insertions(+)

diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LauncherService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LauncherService.java
index 5f32e69..b99cfa7 100644
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LauncherService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LauncherService.java
@@ -17,6 +17,9 @@ public interface LauncherService {
     @Get("/launcher/compaction/stop")
     void compactionStop(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
 
+    @Get("/launcher/compaction/stop")
+    void compactionStop(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("disable_meta") Boolean disableMeta);
+
     @Get("/launcher/compaction/stop_app")
     void compactionStopApp(@Query("application_id") String applicationId);
 }
diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java
index ecef8f2..6db5fe1 100644
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java
@@ -54,6 +54,12 @@ public class LaunchersService {
         }
     }
 
+    public void compactionStop(Long flinkJobId, String alias, Boolean disableMeta) {
+        for (LauncherService service : getServices()) {
+            service.compactionStop(flinkJobId, alias, disableMeta);
+        }
+    }
+
     public void compactionStop(String cluster, Long flinkJobId, String alias) {
         LauncherService service = getService(cluster);
         service.compactionStop(flinkJobId, alias);