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

[HongHuangNeu]

如果输入有回撤流的话，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/

[casel.chen]

我也遇到同样的问题


GroupWindowAggregate doesn't support consuming update and delete changes which is produced by node TableSourceScan(table=[[default_catalog, default_database, mcsp_pay_log, ...

按时间窗口聚合不支持上游是canal-json格式的cdc表的情况么？我的业务表其实是一张日志表，怎样用flink sql将retract table转成append table?

















在 2021-02-04 09:25:10，"HongHuangNeu" <[hidden email]> 写道：

>如果输入有回撤流的话，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/

[HunterXHunter]

toAppendDataStream试试看



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