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