Re: Tumbling window expects a time attribute for grouping in a stream environment

Hi Enrico, that's (for now) the right approach. I agree, that the KafkaTableSource should implement both DefinedXTimeAttribute interfaces. Best, Fabian 2017-05-25 3:20 GMT+02:00 enrico canzonieri : > I solved this implementing a new Kafka09TableSource in my application.

Re: Tumbling window expects a time attribute for grouping in a stream environment

I solved this implementing a new Kafka09TableSource in my application. The class I implemented extends both DefinedRowTimeAttribute and DefinedProcTimeAttribute and it exposes the consumer so that I can assign the timestamp extractor. I'm not sure if this is the right approach, but if that's the

Re: Tumbling window expects a time attribute for grouping in a stream environment

Hi Timo, thanks for your help! I tried to follow the examples in the tests but I still have the same issue. I changed my schema and added an additional field "rowtime". My schema now is: root |-- rowtime: org.apache.flink.table.expressions.RowtimeAttribute(expr: GenericType) |-- time: Long |--

Re: Tumbling window expects a time attribute for grouping in a stream environment

Hi Enrico, the docs of the 1.3-SNAPSHOT are a bit out of sync right now, but they will be updated in the next days/1-2 weeks. We recently introduced so-called "time indicators". These are attributes that correspond to Flink's time and watermarks. You declare a logical field that represents

Tumbling window expects a time attribute for grouping in a stream environment

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