flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From enrico canzonieri <ecanzoni...@gmail.com>
Subject Tumbling window expects a time attribute for grouping in a stream environment
Date Wed, 24 May 2017 02:15:22 GMT
Hi,
I'm trying to window and groupBy a stream using the table api, but I get
ValidationException in the windowing function.
Here is the relevant code:

tableEnv.registerTableSource(schema.getName, src)
val table = tableEnv.scan(schema.getName)
val t = table.window(Tumble over 1.minutes on 'time as 'w).groupBy('host,
'w).select('host)

"time" is defined as Long in my schema. The error I get is:
Exception in thread "main" org.apache.flink.table.api.ValidationException:
TumblingGroupWindow('w, 'time, 60000.millis) is invalid: Tumbling window
expects a time attribute for grouping in a stream environment.

I also tried to define a window that was using processing time, but what
described in the documentation "Tumble over 1.minutes as 'w"  doesn't seem
to work anymore. Specifically it seems that a window now always expects the
"on" call.

Has anybody encountered this issue? I'm using Flink 1.3-SNAPSHOT.

thanks

Mime
View raw message