大家好!请教几个问题
 1. FlinkSQL维表join的时候,能不能把维表先用flinksql 当做一个临时表,然后在用临时表做维表join
例如:临时表
WITH employee_tmp AS(
 select 
 userid as userid,
 name as name,
 mobile as de_mobile 
 from ygp_dwd_catalog.flink_dwd.employee
)
 select
 *
 from ( select
 *
 from ygp_dwd_catalog.flink_dwd.xxx ) t1
 left join employee_tmp FOR SYSTEM_TIME AS OF .....
以上这样写对不对,测试的时候发现是null。
2.维表FOR SYSTEM_TIME AS OF 后面关联条件能否如下方式写:
FOR SYSTEM_TIME AS OF t1.proc_time as t4 on udf(t1.telephone_no) = 
udf(t4.de_mobile)
上面写法报错如下:
 Temporal table join requires an equality condition on fields of table。
但问题的关键是UDF在hive和presto都可以跑起来的。FlinkSQL就报了相同的条件要

回复