Re: 无法生成rowtime导致在window失败

Sun, 28 Jun 2020 22:06:41 -0700 

Hi,

> field("logictime","TIMESTAMP(3)”)
 报错的原因这个字段在你原始的表中不存在的，理解你的需求是你想用 field evitime（Long型）生成一个新的 field 
logictime(TIMESTAMP(3))，这个可以用计算列解决，Table API上还不支持计算列，1.12 已经在开发中了。你可以用 DDL 
加计算列完成满足你的需求，参考[1]

create table test (
 acct STRING,
 evitime BIGINT,
 logictime as TO_TIMESTAMP(FROM_UNIXTIME(evitime)),
 WATERMARK FOR logictime AS logictime - INTERVAL ‘5’ SECOND,
) with(
...
)
 
   
祝好
Leonard
[1] 
https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/sql/create.html
 
<https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/sql/create.html>

回复