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


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



---原始邮件---
发件人: "guoyb"<861277...@qq.com&gt;
发送时间: 2021年3月17日(周三) 下午5:43
收件人: "user-zh"<user-zh@flink.apache.org&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

回复