Hi，amenhub 这个提示是ts字段缺少了时间属性(time attribute)，window中的ts字段需要定义为时间属性，目前Flink支持处理时间（processing time） 和 事件时间（event time），时间属性的定义方式可以参考[1]
[1]https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html <https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html> Best, Leonard > 在 2020年1月6日，16:50，Benchao Li <libenc...@gmail.com> 写道： > > hi amenhub, > > 这个错误的意思是，窗口内引用的字段需要是一个时间字段，可以是事件时间，也可以是处理时间。你需要check一下你的ts字段是不是定义了时间属性。 > > 可以参考下官方文档： > https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sql.html#group-windows > > amenhub <amen...@163.com> 于2020年1月6日周一 下午4:45写道： > >> 各位好， >> >> >> 在使用Flink SQL时，创建如下DDL，使用窗口时报错： >> >> >> INSERT INTO sql_out >> SELECT product_id, TUMBLE_END(ts, INTERVAL '2' MINUTE) AS window_end, >> count(*) AS cnt FROM kafka_out WHERE behavior = 'pv' GROUP BY product_id, >> TUMBLE(ts, INTERVAL '2' MINUTE) >> >> >> 错误信息：Window can only be defined over a time attribute column. 请大佬帮我解惑，谢谢 >> >> >> 祝好 >> >> >> >> >> > > > > -- > > Benchao Li > School of Electronics Engineering and Computer Science, Peking University > Tel:+86-15650713730 > Email: libenc...@gmail.com; libenc...@pku.edu.cn
