please try this approach: interval + interval like this: SELECT count(1) AS event_count , TUMBLE_END(rowtime, INTERVAL '7' HOUR + INTERVAL '30' MINUTE) AS window_timestamp FROM `data_stream` GROUP BY TUMBLE ( rowtime, INTERVAL '7' HOUR + INTERVAL '30' MINUTE)
thanks, godfrey ------------------------------------------------------------------ 发件人:Arujit Pradhan <arujit.prad...@gojek.com> 发送时间:2019年11月21日(星期四) 16:23 收件人:user <user@flink.apache.org> 主 题:Compound Time interval in SQL queries Hi all, Is there a way to define a compound time interval(that can consist of both HOUR and MINUTE) in windows in a Flink SQL query. For example, we want to do something like this: SELECT count(1) AS event_count , TUMBLE_END(rowtime, INTERVAL '7' HOUR AND '30' MINUTE) AS window_timestamp FROM `data_stream` GROUP BY TUMBLE ( rowtime, INTERVAL '7' HOUR '30' MINUTE ) We can not even convert this to Minutes as we are getting this error : Interval field value <xxx> exceeds precision of MINUTE(2) field We were going through Calcite documentation and could not find any workaround on this. Thanks and regards, arujit