diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/B12LauncherService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/B12LauncherService.java
new file mode 100644
index 0000000..c48af18
--- /dev/null
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/B12LauncherService.java
@@ -0,0 +1,11 @@
+package com.lanyuanxiaoyao.service.forest.service.launcher;
+
+import com.dtflys.forest.annotation.BaseRequest;
+
+/**
+ * @author lanyuanxiaoyao
+ * @date 2023-06-06
+ */
+@BaseRequest(baseURL = "http://service-launcher-runner-b12")
+public interface B12LauncherService extends LauncherService{
+}
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 9119642..0787ef0 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
@@ -8,6 +8,12 @@ import com.dtflys.forest.annotation.Query;
  * @date 2023-06-06
  */
 public interface LauncherService {
+    @Get("/launcher/synchronizer/start")
+    void syncStart(Long flinkJobId);
+
+    @Get("/launcher/synchronizer/stop")
+    void syncStop(Long flinkJobId);
+
     @Get("/launcher/compaction/stop")
     void compactionStop(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
 
diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java
index 83aba12..ecef8f2 100644
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/LaunchersService.java
@@ -2,6 +2,8 @@ package com.lanyuanxiaoyao.service.forest.service.launcher;
 
 import cn.hutool.core.util.StrUtil;
 import com.eshore.odcp.hudi.connector.Constants;
+import java.util.HashMap;
+import java.util.Map;
 import org.eclipse.collections.api.factory.Maps;
 import org.eclipse.collections.api.list.ImmutableList;
 import org.eclipse.collections.api.map.ImmutableMap;
@@ -23,18 +25,16 @@ public class LaunchersService {
             A4LauncherService a4LauncherService,
             B1LauncherService b1LauncherService,
             B5LauncherService b5LauncherService,
-            B5SyncLauncherService b5SyncLauncherService
-            ) {
-        serviceMap = Maps.immutable.of(
-                Constants.CLUSTER_A4,
-                a4LauncherService,
-                Constants.CLUSTER_B1,
-                b1LauncherService,
-                Constants.CLUSTER_B5,
-                b5LauncherService,
-                Constants.CLUSTER_B5_SYNC,
-                b5SyncLauncherService
-        );
+            B5SyncLauncherService b5SyncLauncherService,
+            B12LauncherService b12LauncherService
+    ) {
+        Map<String, LauncherService> map = new HashMap<>(5);
+        map.put(Constants.CLUSTER_A4, a4LauncherService);
+        map.put(Constants.CLUSTER_B1, b1LauncherService);
+        map.put(Constants.CLUSTER_B5, b5LauncherService);
+        map.put(Constants.CLUSTER_B5_SYNC, b5SyncLauncherService);
+        map.put(Constants.CLUSTER_B12, b12LauncherService);
+        serviceMap = Maps.immutable.ofAll(map);
     }
 
     private LauncherService getService(String cluster) {