【Flink1.19】 FlinkSQL报错Exception in thread “main” org.apache.flink.table.api.TableException: unexpected correlate variable $cor0 in the plan

执行的SQL

SELECT 
( SELECT COALESCE(aub.bank_card , 'default') AS bank_card 
FROM allygo_user_bank aub 
WHERE aub.user_id = allygo_user.user_id 
ORDER BY create_time LIMIT 1 ) AS bank 
FROM allygo_user limit 100

遇到的错误是由于子查询引用了外部查询中的一列,这会导致 Flink SQL 出现问题。下面是重写查询以避免使用相关子查询的方法:

使用带 WINDOW 函数的 JOIN 来实现相同的结果:

SELECT 
    COALESCE(aub.bank_card, 'default') AS bank_card
FROM 
    allygo_user
LEFT JOIN (
    SELECT 
        user_id, 
        bank_card,
        ROW_NUMBER() OVER (PARTITION BY user_id ORDER BY create_time) as rn
    FROM 
        allygo_user_bank
) aub ON allygo_user.user_id = aub.user_id AND aub.rn = 1
LIMIT 100

说明:

  • 窗口功能: 使用 ROW_NUMBER(),根据创建时间对每个用户 ID 的银行卡进行排序。
  • 连接: 执行 LEFT JOIN,将
    allygoo_user 中的每个用户 ID 与排名靠前的银行卡关联起来。 COALESCE: 如果未找到银行卡,则提供默认值。
  • 限制:将结果限制为 100 行。

这种方法可以避免相关子查询,从而解决错误。

更多推荐