【flink sql group by 时间窗口】

[guoyb]

版本1.12.1

请问，支持事件时间吗？应该设置为哪种时间类型。


as_of_time time
group by xx
, tumble( as_of_time, interval "5" second)


sql client报错，
window aggregate can only be defined over a time attribute column, but time(0) encountered

[guoyb]

这个问题换种写法解决了，从MySQL数据库表里取时间戳字段再转timestamp，可以实现滚动窗口，没报错。


从MySQL表里直接取datetime类型，jdbc表flink设置timestamp类型，会报错，直接取source的时间类型字段是不是转换有点问题。



---原始邮件---
发件人: "guoyb"<[hidden email]&gt;
发送时间: 2021年3月17日(周三) 下午5:43
收件人: "user-zh"<[hidden email]&gt;;
主题: 【flink sql group by 时间窗口】


版本1.12.1

请问，支持事件时间吗？应该设置为哪种时间类型。


as_of_time time
group by xx
, tumble( as_of_time, interval "5" second)


sql client报错，
window aggregate can only be defined over a time attribute column, but time(0) encountered