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

fix(forest): 修复启动同步没有传参数

Browse Source
This commit is contained in:
兰缘小妖
2024-01-01 17:50:48 +08:00
parent 7aedde5086
commit ad41ab9683
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

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