Apache Doris 中文技术论坛
Questions Tags Users Badges

3.0.3,flinksql中lookup-join doris维表关联无法过滤字段

Asked Mar 6, 2025 Modified Mar 6, 2025
Viewed 66
3.0 ingestion

flink环境 1.17.1 1.20.0
doris版本 3.0.3
connector版本:flink-doris-connector-1.16-25.0.0.jar

问题: flinksql中流表kafka数据关联doirs维表,在where条件中过滤维表数据不生效,如果where条件中有类似where Doris.field = xxx 这样会修改原表 Doris.field字段值

维表关联

edited Mar 6, 2025
zhengshunzhi1
asked Mar 6, 2025
1 Answers

你的connector版本和flink版本不一致
image.png

edited Jan 1, 1970
黄海军@SelectDB5218
answered Mar 7, 2025
Related Questions
ccr数据同步成功了,但是执行get_lag的last_binlog_timestamp和first_binlog_timestamp为什么都是1970-01-01 08:00:00,我该怎么查看上次同步时间呢
1 answers
物化视图创建-使用LATERAL VIEW EXPLODE_OUTER
2 answers
使用doris物化视图做数仓分层,哪种策略好
1 answers
3.0.8版本查hive外表报错:[INTERNAL_ERROR][E6] Parameters start = 0, length = 1, are out of bound
1 answers
Doris漏洞
1 answers
DBA岗位招聘
1 answers

Terms of service Privacy policy

Powered by Answer - the open-source software that powers Q&A communities.
Made with love © 2026 Apache Doris 中文技术论坛.