you have further question, feel free to ask them. It helps us to
>>> improve the documenation.
>>>
>>> Regards,
>>> Timo
>>>
>>>
>>>
>>> Am 24.05.17 um 04:15 schrieb enrico canzonieri:
>>>
>>> Hi,
>>&
5 schrieb enrico canzonieri:
>>
>> 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)
>
'w).select('host)
I still get the previous error:
TumblingGroupWindow('w, 'rowtime, 60000.millis) is invalid: Tumbling window
expects a time attribute for grouping in a stream environment.
I'm using a Kafka09TableSource as data source, but it doesn't allow me to
specif
('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
27;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, 6.millis) is invalid: Tumbl
