From de4b85cad6ed71430ccb2de17e6347d15318addf Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Tue, 2 Jan 2024 09:22:48 +0800 Subject: [PATCH] =?UTF-8?q?fix(info-query):=20=E4=BF=AE=E5=A4=8Dflink=20jo?= =?UTF-8?q?b=E6=B2=A1=E6=9C=89one=20in=20one=E9=85=8D=E7=BD=AE=E6=97=B6?= =?UTF-8?q?=E5=80=99=E6=9F=A5=E8=AF=A2=E4=B8=8D=E5=88=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 使用左连接来取一些可能不存在的关联值 --- .../lanyuanxiaoyao/service/info/service/InfoService.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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 4ab086b..b9d9a9c 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 @@ -275,9 +275,10 @@ public class InfoService { TbAppYarnJobConfig.JOB_MANAGER_MEMORY_A, TbAppYarnJobConfig.TASK_MANAGER_MEMORY_A ) - .from(TbAppFlinkJobConfig._alias_, TbAppYarnJobConfig._alias_) - .whereEq(TbAppFlinkJobConfig.ONE_IN_ONE_YARN_JOB_ID_A, Column.as(TbAppYarnJobConfig.ID_A)) - .andEq(TbAppFlinkJobConfig.STATUS_A, STATUS_Y) + .from(TbAppFlinkJobConfig._alias_) + .leftJoin(TbAppYarnJobConfig._alias_) + .onEq(TbAppFlinkJobConfig.ONE_IN_ONE_YARN_JOB_ID_A, Column.as(TbAppYarnJobConfig.ID_A)) + .whereEq(TbAppFlinkJobConfig.STATUS_A, STATUS_Y) .andEq(ObjectUtil.isNotNull(flinkJobId), TbAppFlinkJobConfig.ID_A, flinkJobId) .build(), (rs, row) -> {