feat(web): 增加一个停止全部压缩任务的小工具

2024-01-29 15:47:25 +08:00
parent c6c4021930
commit 4b2585984c
4 changed files with 62 additions and 0 deletions
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/ScheduleService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/ScheduleService.java
@@ -35,4 +35,7 @@ public interface ScheduleService {

    @Get("/table")
    void scheduleTableRecommend(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("recommend") String recommendCluster);
+
+    @Get("/stop_all")
+    void stopAll(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("disable_meta") Boolean disableMeta);
 }