From ad41ab9683cef453ac4e671e4b99c84aa5d21d14 Mon Sep 17 00:00:00 2001
From: lanyuanxiaoyao <lanyuanxiaoyao@gmail.com>
Date: Mon, 1 Jan 2024 17:50:48 +0800
Subject: [PATCH] =?UTF-8?q?fix(forest):=20=E4=BF=AE=E5=A4=8D=E5=90=AF?=
 =?UTF-8?q?=E5=8A=A8=E5=90=8C=E6=AD=A5=E6=B2=A1=E6=9C=89=E4=BC=A0=E5=8F=82?=
 =?UTF-8?q?=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/forest/service/launcher/LauncherService.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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