diff --git a/service-web/src/main/java/com/lanyuanxiaoyao/service/web/entity/TableVO.java b/service-web/src/main/java/com/lanyuanxiaoyao/service/web/entity/TableVO.java index 001a35a..e529177 100644 --- a/service-web/src/main/java/com/lanyuanxiaoyao/service/web/entity/TableVO.java +++ b/service-web/src/main/java/com/lanyuanxiaoyao/service/web/entity/TableVO.java @@ -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; }