ot;,
>
>"D:\\conf", "1.1.0");
>
> tEnv.registerCatalog("x", myCatalog);
>
> Best,
> Junbao Zhang
>
> ________________
> 发件人: Leonard Xu
> 发送时间: 2020年5月20日 11:51
> 收件人: user-zh
> 主题: Re: flink sql使用维表关联时报Temporal table join c
t; tEnv.registerCatalog("x", myCatalog);
>
> Best,
> Junbao Zhang
>
> ________________
> 发件人: Leonard Xu
> 发送时间: 2020年5月20日 11:51
> 收件人: user-zh
> 主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
> SYSTEM_TIME AS OF' left table's proctime field
发件人: Leonard Xu
发送时间: 2020年5月20日 11:51
收件人: user-zh
主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'
Hi,wind
用你的sql没有报类似的问题,请确认下版本是1.10.x吗?
另外不建议表名用 x.log.yanfa_log 包含 “.”
这个关键字符,这和表的全名:catalo
t;
> Best,
> Junbao Zhang
> ________________
> 发件人: Leonard Xu
> 发送时间: 2020年5月20日 10:50
> 收件人: user-zh
> 主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
> SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'
日 10:50
收件人: user-zh
主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'
Hi,
1.10(1.10.1)版本都是支持建表时用计算列声明proctime列的,temporal table也是支持join 和 left
join的,我这边之前1.10 release时验证过[1],可以参考
方便把你们完整的sql 贴出来
_
> 发件人: 祝尚 <17626017...@163.com>
> 发送时间: 2020年5月19日 0:02
> 收件人: 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()'
>
> 可以的吧,ja
我就是按照这里面的语法去做的,试验没有成功,能把你试验的create table和query sql语句贴出来吗?谢谢。
发件人: 祝尚 <17626017...@163.com>
发送时间: 2020年5月19日 0:02
收件人: user-zh@flink.apache.org
主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
SYSTEM_TIME AS OF' left table's proctime
t; Hi,
> 经过尝试,select时候调用PROCTIME()函数生成proctime字段是可行的,谢谢。
>
> 发件人: 111
> 发送时间: 2020年5月18日 16:07
> 收件人: user-zh@flink.apache.org
> 主题: 回复: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
> SYSTEM_TIME AS OF' left table's proct
Hi,
经过尝试,select时候调用PROCTIME()函数生成proctime字段是可行的,谢谢。
发件人: 111
发送时间: 2020年5月18日 16:07
收件人: 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
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
HI,
遇到相同的情况 +1,Flink 1.10.1同样不好使。
Best,
Xinghalo
是的,应该是AS PROCTIME(),是我的笔误。但是同样的错误还会报。
发件人: Benchao Li
发送时间: 2020年5月18日 12:59
收件人: user-zh
主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()'
你第二次贴的DDL好像也有些问题,是不是
e' = 'latest-offset',
> 'update-mode' = 'append',
> 'format.type' = 'json',
> 'format.fail-on-missing-field' = 'true'
> );
> 报同样的错误
>
> -邮件原件-
> 发件人: wind.fly....@outlook.com
> 发送时间: 2020年5月18日 9:45
> 收件人: user-zh@flink.apache.org
> 主题: flink sql
@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, all:
本人使用的flink 版本为1.10.0,planner为BlinkPlanner,用LEFT JOIN FOR SYSTEM_TIME AS
OF 语法关联维表:
select TUMBLE_END(l.dt
Hi, all:
本人使用的flink 版本为1.10.0,planner为BlinkPlanner,用LEFT JOIN FOR SYSTEM_TIME AS
OF 语法关联维表:
select TUMBLE_END(l.dt, INTERVAL '30' SECOND) as index_time,
l.extra_info['cityCode'] as city_code, v.vehicle_level as vehicle_level,
CAST(COUNT(DISTINCT req_body['driverId']) as STRING) as
15 matches
Mail list logo