SELECT TUMBLE_START(event_timestamp, INTERVAL '1' HOUR), COUNT(DISTINCT session), COUNT(DISTINCT user_id), SUM(duration), SUM(num_interactions) FROM unified_events GROUP BY TUMBLE(event_timestamp, INTERVAL '1' HOUR)
I have the above statement my flink query running on Flink 1.3.2, but got the error message Caused by: org.apache.flink.table.api.TableException: Cannot generate a valid execution plan for the given query Is the feature supported yet? if Yes, in which version of flink? If no, any timeline to support it? Thanks, Tao -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/