From 303ff580f5d0acfc6559f30c1d073966b857b688 Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Tue, 13 Jun 2023 00:55:57 +0800 Subject: [PATCH] =?UTF-8?q?fix(info-query):=20=E4=BF=AE=E5=A4=8D=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E7=89=88=E6=9C=AC=E6=B2=A1=E6=9C=89=E5=8C=BA=E5=88=86?= =?UTF-8?q?=E8=B7=A8=E5=A4=A9=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lanyuanxiaoyao/service/info/service/InfoService.java | 2 ++ 1 file changed, 2 insertions(+) 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(),