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
发件人: 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_lo
x27; = 'append',
>'format.type' = 'json',
>'format.fail-on-missing-field' = 'true'
> );
>
> join sql 可以查看历史记录里面有。
>
> Best,
> Junbao Zhang
>
> 发件人: Leonard Xu
> 发送时间: 2020年5月2
27;json',
'format.fail-on-missing-field' = 'true'
);
join sql 可以查看历史记录里面有。
Best,
Junbao Zhang
____________
发件人: Leonard Xu
发送时间: 2020年5月20日 10:50
收件人: user-zh
主题: Re: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
SYSTEM_T
_
> 发件人: 祝尚 <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 'PROCT
我就是按照这里面的语法去做的，试验没有成功，能把你试验的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&
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 tab
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,
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
'connector.properties.zookeeper.connect' = '**:2181',
> 'connector.startup-mode' = 'latest-offset',
> 'update-mode' = 'append',
> 'format.type' = 'json',
> 'format.fail-on-missing-fi
at.type' = 'json',
'format.fail-on-missing-field' = 'true'
);
报同样的错误
-----邮件原件-----
发件人: wind.fly@outlook.com
发送时间: 2020年5月18日 9:45
收件人: user-zh@flink.apache.org
主题: flink sql使用维表关联时报Temporal table join currently only supports 'FOR
SYSTEM_TIME
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
