lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(info-query): 修复flink job没有one in one配置时候查询不到

Browse Source 
使用左连接来取一些可能不存在的关联值
This commit is contained in:
兰缘小妖
2024-01-02 09:22:48 +08:00
parent d4e39bdaf1
commit de4b85cad6
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java
View File

@@ -275,9 +275,10 @@ public class InfoService {
TbAppYarnJobConfig.JOB_MANAGER_MEMORY_A, TbAppYarnJobConfig.JOB_MANAGER_MEMORY_A,
TbAppYarnJobConfig.TASK_MANAGER_MEMORY_A TbAppYarnJobConfig.TASK_MANAGER_MEMORY_A
) )
.from(TbAppFlinkJobConfig._alias_, TbAppYarnJobConfig._alias_) .from(TbAppFlinkJobConfig._alias_)
.whereEq(TbAppFlinkJobConfig.ONE_IN_ONE_YARN_JOB_ID_A, Column.as(TbAppYarnJobConfig.ID_A)) .leftJoin(TbAppYarnJobConfig._alias_)
.andEq(TbAppFlinkJobConfig.STATUS_A, STATUS_Y) .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) .andEq(ObjectUtil.isNotNull(flinkJobId), TbAppFlinkJobConfig.ID_A, flinkJobId)
.build(), .build(),
(rs, row) -> { (rs, row) -> {