feature(web): 适配上游更新

This commit is contained in:
2023-06-02 10:10:16 +08:00
parent 6af04ce1f6
commit e0d8be7af1

View File

@@ -36,7 +36,7 @@ public class TableVO {
this.compactionRuntime = compactionRuntime;
if (ObjectUtil.isNotNull(flinkJob) && ObjectUtil.isNotNull(tableMeta)) {
this.syncJobName = NameHelper.syncJobName(this.flinkJob.getId(), this.flinkJob.getName());
this.compactionJobName = NameHelper.compactionJobName(this.flinkJob.getId(), this.tableMeta.getSchema(), this.tableMeta.getAlias());
this.compactionJobName = NameHelper.compactionJobName(this.flinkJob.getId(), this.tableMeta.getAlias());
}
this.syncState = syncState;
}