From: Renjie Liu <liurenjie2...@gmail.com> Date: Tuesday, November 1, 2022 at 15:13 To: u...@flink.apache.org <u...@flink.apache.org> Subject: Why streaming over agg not supporting ranged upper boundary? Hi, flink community:
Per the doc here https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/sql/queries/over-agg/#range-definitions Flink streaming over agg only supports current row as upper boundary. I can understand it’s impossible to support unlimited upper boundary, but I don’t know why we can’t support ranges upper boundary? For example I believe following sql is reasonable: SELECT order_id, order_time, amount, SUM(amount) OVER ( PARTITION BY product ORDER BY order_time RANGE BETWEEN INTERVAL '1' HOUR PRECEDING AND INTERVAL '1' HOUR AFTER ) AS one_hour_prod_amount_sum FROM Orders
