lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(forest): 压缩调度增加不删除表停止全部压缩的参数

Browse Source
This commit is contained in:
兰缘小妖
2024-01-29 10:42:25 +08:00
parent 348b3b7028
commit c6c4021930
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LauncherService.java
View File

@@ -17,6 +17,9 @@ public interface LauncherService {
@Get("/launcher/compaction/stop") @Get("/launcher/compaction/stop")
void compactionStop(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); 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") @Get("/launcher/compaction/stop_app")
void compactionStopApp(@Query("application_id") String applicationId); void compactionStopApp(@Query("application_id") String applicationId);
} }

6
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java
View File

@@ -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) { public void compactionStop(String cluster, Long flinkJobId, String alias) {
LauncherService service = getService(cluster); LauncherService service = getService(cluster);
service.compactionStop(flinkJobId, alias); service.compactionStop(flinkJobId, alias);