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

Viewed 25

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