Fabian Hueske created FLINK-7955: ------------------------------------ Summary: Rowtime attribute cannot be aggregated in group window of stream Table API Key: FLINK-7955 URL: https://issues.apache.org/jira/browse/FLINK-7955 Project: Flink Issue Type: Bug Components: Table API & SQL Affects Versions: 1.3.2, 1.4.0 Reporter: Fabian Hueske
The following query fails with a {{NullPointerException}}: {code} val windowedTable = table .window(Tumble over 5.milli on 'rowtime as 'w) .groupBy('w, 'word) .select('word, 'rowtime.count, 'w.start, 'w.end) {code} Equivalent SQL queries or Table API queries that use a processing time attribute are working. -- This message was sent by Atlassian JIRA (v6.4.14#64029)