使用Flink SQL时，碰到的 【Window can only be defined over a time attribute column】

Mon, 06 Jan 2020 00:46:16 -0800 

各位好，


在使用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. 请大佬帮我解惑，谢谢


祝好

回复