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 0787ef0..5f32e69 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 @@ -9,10 +9,10 @@ import com.dtflys.forest.annotation.Query; */ public interface LauncherService { @Get("/launcher/synchronizer/start") - void syncStart(Long flinkJobId); + void syncStart(@Query("flink_job_id") Long flinkJobId); @Get("/launcher/synchronizer/stop") - void syncStop(Long flinkJobId); + void syncStop(@Query("flink_job_id") Long flinkJobId); @Get("/launcher/compaction/stop") void compactionStop(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);