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

2020-01-06 文章 amenhub
hi Benchao, 刚才了解到,flink1.9版本不支持DDL time以及watermark语义的定义,所以是因此不支持window窗口函数需要的时间属性。期待1.10发布~ 祝好 在 2020-01-06 16:50:03,"Benchao Li" 写道: >hi amenhub, > >这个错误的意思是,窗口内引用的字段需要是一个时间字段,可以是事件时间,也可以是处理时间。你需要check一下你的ts字段是不是定义了时间属性。 > >可以参考下官方文档:

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

2020-01-06 文章 Leonard Xu
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

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

2020-01-06 文章 Benchao Li
hi amenhub, 这个错误的意思是,窗口内引用的字段需要是一个时间字段,可以是事件时间,也可以是处理时间。你需要check一下你的ts字段是不是定义了时间属性。 可以参考下官方文档: https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sql.html#group-windows amenhub 于2020年1月6日周一 下午4:45写道: > 各位好, > > > 在使用Flink SQL时,创建如下DDL,使用窗口时报错: > > > INSERT INTO sql_out >

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

2020-01-06 文章 amenhub
各位好, 在使用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

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

2020-01-06 文章 amenhub
各位好,