diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/VersionService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/VersionService.java
index 9bec384..84e1467 100644
--- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/VersionService.java
+++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/VersionService.java
@@ -175,7 +175,7 @@ public class VersionService extends BaseService {
                         TbAppCollectTableVersion._alias_,
                         TbAppHudiSyncState._alias_
                 )
-                .whereEq(TbAppFlinkJobConfig.ID_A, Column.as(TbAppCollectTableInfo.ALIAS_A))
+                .whereEq(TbAppFlinkJobConfig.ID_A, Column.as(TbAppCollectTableInfo.FLINK_JOB_ID_A))
                 .andEq(TbAppFlinkJobConfig.STATUS_A, "y")
                 .andEq(TbAppCollectTableInfo.STATUS_A, "y")
                 .andEq(TbAppCollectTableVersion.FLINK_JOB_ID_A, Column.as(TbAppFlinkJobConfig.ID_A))
@@ -246,7 +246,7 @@ public class VersionService extends BaseService {
                     .toImmutable();
             String listSQL = generateVersionTableCriteria(
                     SqlBuilder.select(
-                            TbAppCollectTableInfo.FLINK_JOB_ID_A,
+                            TbAppFlinkJobConfig.ID_A,
                             TbAppCollectTableInfo.ALIAS_A,
                             TbAppCollectTableVersion.VERSION_A,
                             TbAppCollectTableVersion.SCHEDULED_A