From 1a271d84f2badec050f6602e8b0f6bddeea50895 Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Wed, 3 Jan 2024 16:50:22 +0800 Subject: [PATCH] =?UTF-8?q?fix(info-query):=20=E4=BF=AE=E5=A4=8D=E8=B7=A8?= =?UTF-8?q?=E5=A4=A9=E6=9F=A5=E8=AF=A2=E5=AD=97=E6=AE=B5=E5=8C=B9=E9=85=8D?= =?UTF-8?q?=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lanyuanxiaoyao/service/info/service/VersionService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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