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

2021-03-17 文章 guoyb
这个问题换种写法解决了,从MySQL数据库表里取时间戳字段再转timestamp,可以实现滚动窗口,没报错。 从MySQL表里直接取datetime类型,jdbc表flink设置timestamp类型,会报错,直接取source的时间类型字段是不是转换有点问题。 ---原始邮件--- 发件人: "guoyb"<861277...@qq.com 发送时间: 2021年3月17日(周三) 下午5:43 收件人: "user-zh"

【flink sql group by 时间窗口】

2021-03-17 文章 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