flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "wind.fly.vip@outlook.com" <wind.fly....@outlook.com>
Subject 回复: flink sql使用维表关联时报Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'
Date Tue, 19 May 2020 01:23:56 GMT
我就是按照这里面的语法去做的,试验没有成功,能把你试验的create
table和query sql语句贴出来吗?谢谢。
________________________________
发件人: 祝尚 <17626017841@163.com>
发送时间: 2020年5月19日 0:02
收件人: user-zh@flink.apache.org <user-zh@flink.apache.org>
主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'

可以的吧,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