如果输入有回撤流的话，group by时间窗口会遇到GroupWindowAggregate doesn't support consuming update and delete changes

Wed, 03 Feb 2021 17:24:30 -0800 

如果输入有回撤流的话，group by时间窗口会遇到GroupWindowAggregate doesn't support consuming
update and delete changes，有没有什么替代方案？输入是来自于流式去重，就是

SELECT [column_list]
FROM (
   SELECT [column_list],
     ROW_NUMBER() OVER ([PARTITION BY col1[, col2...]]
       ORDER BY time_attr [asc|desc]) AS rownum
   FROM table_name)
WHERE rownum = 1

这样的语句



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复