[ https://issues.apache.org/jira/browse/FLINK-26802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser closed FLINK-26802. ---------------------------------- Resolution: Duplicate > 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)