flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 祝尚 <17626017...@163.com>
Subject Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'
Date Mon, 18 May 2020 16:02:32 GMT
可以的吧,jark大佬的例子http://wuchong.me/blog/2020/02/25/demo-building-real-time-application-with-flink-sql/
<http://wuchong.me/blog/2020/02/25/demo-building-real-time-application-with-flink-sql/>
也是这么用的,我也试过sql client和table api里面都没问题

> 2020年5月18日 下午4:43,wind.fly.vip@outlook.com 写道:
> 
> Hi,
>   经过尝试,select时候调用PROCTIME()函数生成proctime字段是可行的,谢谢。
> ________________________________
> 发件人: 111 <xinghalo@163.com>
> 发送时间: 2020年5月18日 16:07
> 收件人: user-zh@flink.apache.org <user-zh@flink.apache.org>
> 主题: 回复: flink sql使用维表关联时报Temporal table join currently only
supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'
> 
> Hi,
> 
> 
> 试验了下,proctime不能在建表时创建。需要在select的时候基于PROCTIME()函数生成。
> 
> 
> 比如:
> Select …., PROCTIME() AS proctime from xxx;
> Select * from xxx t1 left join yyy for system_time as of t1.proctime as t2 on t1.id =
t2.id;
> 这样才行。
> 
> 
> Best,
> Xinghalo


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message