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

Viewed 49
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
doris2.1.5升级到doris3.0.8，升级后开启ranger，root执行SHOW PROC '/backends' 报没有admin权限
routine load只支持部分列更新，不支持灵活列更新，什么时候能支持？
1 answers
为什么采用AGGREGATE KEY引擎的REPLACE_IF_NOT_NULL，最后的查询巨慢？
1 answers
Spark Doris Connector 写入 doris 云服务器内网不可达
1 answers
存算分离创建 STORAGE VAULT 问题，hdfs高可用下dfs.client.failover.proxy.provider.mycluster配置问题
1 answers
the report queue size exceeds the limit: xxx
1 answers