求助:lookup join on中多条件失效

flinksql 如下:

select t.* 
from real_data_table t 
left join dim_data_table for system_time as of t.proc_time as dt 
on t.id = dt.source_id and dt.latest=1

将日志级别调整到debug, 发现lookup join在查询dim_data_table 时,只使用了一个条件 既:source_id = ?

需要怎样做才能让 dt.latest=1这个条件在lookup join的时候生效

展开
收起
1981120303102140 2025-07-02 17:52:53 68 分享 版权
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理