feat(command): 初始化sync_state表

2024-03-14 17:15:12 +08:00
parent 2a7e6639e7
commit a4675960f6
1 changed files with 2 additions and 0 deletions
--- 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));
            }
        }
    }