flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Leonard Xu <xbjt...@gmail.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 Wed, 20 May 2020 02:50:48 GMT
Hi,

1.10(1.10.1)版本都是支持建表时用计算列声明proctime列的,temporal table也是支持join
和 left join的,我这边之前1.10 release时验证过[1],可以参考
方便把你们完整的sql 贴出来吗?


Best,
Leonard Xu
[1]
https://github.com/leonardBang/flink-sql-etl/blob/master/etl-job/src/main/resources/job-sql-1.10/kafka2hbase/KafkaJoinHbaseJoinMysql2Hbase.sql
<https://github.com/leonardBang/flink-sql-etl/blob/master/etl-job/src/main/resources/job-sql-1.10/kafka2hbase/KafkaJoinHbaseJoinMysql2Hbase.sql>


> 在 2020年5月19日,09:23,wind.fly.vip@outlook.com 写道:
> 
> 我就是按照这里面的语法去做的,试验没有成功,能把你试验的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