[
https://issues.apache.org/jira/browse/FLINK-26802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656695#comment-17656695
]
Robert Metzger commented on FLINK-26802:
----------------------------------------
I think this is a known limitation tracked here:
https://issues.apache.org/jira/browse/FLINK-19059
> StreamPhysicalOverAggregate doesn't support consuming update and delete
> changes which is produced by node Deduplicate
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-26802
> URL: https://issues.apache.org/jira/browse/FLINK-26802
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.14.4
> Environment: flink version 1.14
> flink sql job
> Reporter: zhiyuan
> Priority: Major
> Attachments: image-2022-03-22-17-28-17-759.png,
> image-2022-03-22-17-37-09-443.png
>
>
> Problem description：
> using topn to de-duplicate, another layer of topN queries is nested
> tran_tm Is defined as watermark
> sql ：
> !image-2022-03-22-17-28-17-759.png!
>
> I tested it and found that using ProcTime worked, but using RowTime had
> syntax problems
>
> !image-2022-03-22-17-37-09-443.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
