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>
发送时间: 2021年3月17日(周三) 下午5:43
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: 【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