From a4675960f61e82d3c781f924d1c2199ba55f50c8 Mon Sep 17 00:00:00 2001
From: v-zhangjc9 <v-zhangjc9.gd@chinatelecom.cn>
Date: Thu, 14 Mar 2024 17:15:12 +0800
Subject: [PATCH] =?UTF-8?q?feat(command):=20=E5=88=9D=E5=A7=8B=E5=8C=96syn?=
 =?UTF-8?q?c=5Fstate=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/command/commands/jobs/AbstractAdder.java            | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/jobs/AbstractAdder.java b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/jobs/AbstractAdder.java
index f9fa15d..b5802a8 100644
--- a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/jobs/AbstractAdder.java
+++ b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/jobs/AbstractAdder.java
@@ -1,6 +1,7 @@
 package com.lanyuanxiaoyao.service.command.commands.jobs;
 
 import cn.hutool.core.lang.Snowflake;
+import cn.hutool.core.util.StrUtil;
 import com.lanyuanxiaoyao.service.common.entity.FlinkJob;
 import com.lanyuanxiaoyao.service.configuration.entity.info.TableMetaAdd;
 import com.lanyuanxiaoyao.service.forest.service.InfoService;
@@ -70,6 +71,7 @@ public abstract class AbstractAdder implements Adder {
                         t.filterType,
                         t.bucketNumber
                 ));
+                infoService.saveSyncState(StrUtil.format("{}-{}", j.id, t.alias));
             }
         }
     }