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) -> {