You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by guoyb <86...@qq.com> on 2021/03/17 10:16:03 UTC

回复:【flink sql group by 时间窗口】

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


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



---原始邮件---
发件人: "guoyb"<861277329@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