You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Liu Join <lz...@outlook.com> on 2021/09/28 08:48:14 UTC

撤回流如何进行窗口分组聚合

我将数据流进行去重后，无法进行窗口聚合操作，一直报错GroupWindowAggregate doesn't support consuming update and delete changes which is produced by node Deduplicate

Re: 撤回流如何进行窗口分组聚合

Posted by Shuo Cheng <nj...@gmail.com>.

这个在 1.14 已经支持了, 详见 FLINK-20487

On 9/28/21, Liu Join <lz...@outlook.com> wrote:
> 我将数据流进行去重后，无法进行窗口聚合操作，一直报错GroupWindowAggregate doesn't support consuming
> update and delete changes which is produced by node Deduplicate
>