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

fix(info-query): 修复跨天查询字段匹配错误

Browse Source
This commit is contained in:
兰缘小妖
2024-01-03 16:50:22 +08:00
parent 59c3ac4c8a
commit 1a271d84f2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/VersionService.java
View File

@@ -175,7 +175,7 @@ public class VersionService extends BaseService {
TbAppCollectTableVersion._alias_, TbAppCollectTableVersion._alias_,
TbAppHudiSyncState._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(TbAppFlinkJobConfig.STATUS_A, "y")
.andEq(TbAppCollectTableInfo.STATUS_A, "y") .andEq(TbAppCollectTableInfo.STATUS_A, "y")
.andEq(TbAppCollectTableVersion.FLINK_JOB_ID_A, Column.as(TbAppFlinkJobConfig.ID_A)) .andEq(TbAppCollectTableVersion.FLINK_JOB_ID_A, Column.as(TbAppFlinkJobConfig.ID_A))
@@ -246,7 +246,7 @@ public class VersionService extends BaseService {
.toImmutable(); .toImmutable();
String listSQL = generateVersionTableCriteria( String listSQL = generateVersionTableCriteria(
SqlBuilder.select( SqlBuilder.select(
TbAppCollectTableInfo.FLINK_JOB_ID_A, TbAppFlinkJobConfig.ID_A,
TbAppCollectTableInfo.ALIAS_A, TbAppCollectTableInfo.ALIAS_A,
TbAppCollectTableVersion.VERSION_A, TbAppCollectTableVersion.VERSION_A,
TbAppCollectTableVersion.SCHEDULED_A TbAppCollectTableVersion.SCHEDULED_A