diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java
index e80fd9d..be239f3 100644
--- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java
+++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java
@@ -116,7 +116,7 @@ public class TableMetaService extends BaseService {
                 .andEq(TbAppHudiSyncState.ID_A, Column.as(StrUtil.format("concat({}, '-', {})", TbAppFlinkJobConfig.ID_A, TbAppCollectTableInfo.ALIAS_A)))
                 .andEq(ObjectUtil.isNotNull(flinkJobId), TbAppFlinkJobConfig.ID_A, flinkJobId)
                 .andEq(StrUtil.isNotBlank(aliasText), TbAppCollectTableInfo.ALIAS_A, aliasText)
-                .andEq(ObjectUtil.isNotNull(priority), TbAppCollectTableInfo.PRIORITY_A, priority)
+                .andGe(ObjectUtil.isNotNull(priority), TbAppCollectTableInfo.PRIORITY_A, priority)
                 .andEq(StrUtil.isNotBlank(hdfs), TbAppCollectTableInfo.TGT_HDFS_PATH_A, hdfs)
                 .andEq(TbAppCollectTableInfo.STATUS_A, STATUS_Y)
                 .andEq(TbAppFlinkJobConfig.STATUS_A, STATUS_Y)
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 7d8f28f..fcaf173 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
@@ -70,9 +70,9 @@ public class VersionService extends BaseService {
                 .andEq(TbAppCollectTableInfo.STATUS_A, "y")
                 .andEq(TbAppFlinkJobConfig.ID_A, Column.as(TbAppCollectTableVersion.FLINK_JOB_ID_A))
                 .andEq(TbAppCollectTableInfo.ALIAS_A, Column.as(TbAppCollectTableVersion.ALIAS_A))
-                .andEq(TbAppCollectTableInfo.PRIORITY_A, 10000)
+                .andLt(TbAppCollectTableInfo.PRIORITY_A, 10000)
                 .andEq(TbAppCollectTableInfo.SCHEDULE_ID_A, false)
-                .andEq(TbAppCollectTableVersion.VERSION_A, "2018");
+                .andEq(TbAppCollectTableVersion.VERSION_A, version);
     }
 
     @Cacheable(value = "un-scheduled-normal-table", sync = true)