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

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字段值

维表关联

1 Answers

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

黄海军@SelectDB5218
Related Questions
3.0.8版本be节点从3个升级到5个，业务高峰期读延迟大
1 answers
doris3.0.8 3台中一台be节点偶发性宕机
2 answers
关于数值类型decimalv3兼容性问题
2 answers
ccr任务job_progress接口-子任务的binlog_type字段都有哪些枚举值
1 answers
ccr数据同步成功了,但是执行get_lag的last_binlog_timestamp和first_binlog_timestamp为什么都是1970-01-01 08:00:00，我该怎么查看上次同步时间呢
1 answers
使用doris物化视图做数仓分层，哪种策略好
1 answers