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);