diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java index 600fad4..61d652e 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java @@ -391,6 +391,7 @@ public class InfoService { .onEq(TABLE_INFO_FLINK_JOB_ID, Column.as(TABLE_VERSION_FLINK_JOB_ID)) .andEq(TABLE_INFO_ALIAS, Column.as(TABLE_VERSION_ALIAS)) .whereLt(TABLE_INFO_PRIORITY, 10000) + .andEq(TABLE_VERSION_SCHEDULED, false) .andEq(TABLE_VERSION_VERSION, version) .andEq(TABLE_INFO_STATUS, "y") .build(), @@ -408,6 +409,7 @@ public class InfoService { .onEq(TABLE_INFO_FLINK_JOB_ID, Column.as(TABLE_VERSION_FLINK_JOB_ID)) .andEq(TABLE_INFO_ALIAS, Column.as(TABLE_VERSION_ALIAS)) .whereGe(TABLE_INFO_PRIORITY, 10000) + .andEq(TABLE_VERSION_SCHEDULED, false) .andEq(TABLE_VERSION_VERSION, version) .andEq(TABLE_INFO_STATUS, "y") .build(),