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

Posted by Leonard Xu on Jan 06, 2020; 9:03am
URL: http://apache-flink.370.s1.nabble.com/Flink-SQL-Window-can-only-be-defined-over-a-time-attribute-column-tp1407p1410.html

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 <[hidden email]> 写道：
>
> hi amenhub,
>
> 这个错误的意思是，窗口内引用的字段需要是一个时间字段，可以是事件时间，也可以是处理时间。你需要check一下你的ts字段是不是定义了时间属性。
>
> 可以参考下官方文档：
> https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sql.html#group-windows
>
> amenhub <[hidden email]> 于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:[phone]
> Email: [hidden email]; [hidden email]