diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java
index 886c2d5..009853f 100644
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java
@@ -104,6 +104,9 @@ public interface InfoService {
     @Get("/info/sync_state/save_compaction_id")
     void saveCompactionId(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("application_id") String applicationId);
 
+    @Get("/info/sync_state/save")
+    void saveSyncState(@Query("id") String id);
+
     @Get("/info/non_updated_version_tables")
     ImmutableList<String> nonUpdatedVersionTables();
 
diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java
index 90869b6..3da53e6 100644
--- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java
+++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java
@@ -39,4 +39,9 @@ public class SyncStateController {
     ) {
         syncStateService.saveCompactionApplicationId(flinkJobId, alias, applicationId);
     }
+
+    @GetMapping("/sync_state/save")
+    public void saveCompactionId(@RequestParam("id") String id) {
+        syncStateService.saveSyncState(id);
+    }
 }
diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java
index 01e1443..3036590 100644
--- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java
+++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java
@@ -101,4 +101,20 @@ public class SyncStateService extends BaseService {
                 applicationId
         );
     }
+
+    @Retryable(Throwable.class)
+    public void saveSyncState(String id) {
+        mysqlJdbcTemplate.update(
+                SqlBuilder.insertInto(
+                                TbAppHudiSyncState._origin_,
+                                TbAppHudiSyncState.ID_O,
+                                TbAppHudiSyncState.MESSAGE_ID_O
+                        )
+                        .values()
+                        .addValue(Q, Q)
+                        .precompileSql(),
+                id,
+                "-1:-1:-1"
+        );
+    }
 }