[
https://issues.apache.org/jira/browse/FLINK-26802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhiyuan updated FLINK-26802:
----------------------------
Attachment: image-2022-03-22-17-37-09-443.png
Description:
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!
was:
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
> 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.1#820001)
