[ https://issues.apache.org/jira/browse/FLINK-27969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser closed FLINK-27969. ---------------------------------- Resolution: Delivered > StreamPhysicalOverAggregate doesn't support consuming update and delete > changes > ------------------------------------------------------------------------------- > > Key: FLINK-27969 > URL: https://issues.apache.org/jira/browse/FLINK-27969 > Project: Flink > Issue Type: Bug > Components: Table SQL / API > Affects Versions: 1.14.3 > Reporter: Spongebob > Priority: Major > > Exception trace: > {code:java} > // exception > StreamPhysicalOverAggregate doesn't support consuming update and delete > changes which is produced by node Join(joinType=[LeftOuterJoin], where=[(COL2 > = COL4)], select=[...], leftInputSpec=[NoUniqueKey], > rightInputSpec=[NoUniqueKey]) {code} > FlinkSQL that scheduled as streaming table like this: > {code:java} > // dml > SELECT RANK() OVER (PARTITION BY A.COL1 ORDER BY A.COL2) AS ODER_ONUM > FROM A > INNER JOIN B ON A.COL1 = B.COL1 > LEFT JOIN C ON C.COL3 = 1 AND CAST(A.COL2 AS STRING) = C.COL4{code} > -- This message was sent by Atlassian Jira (v8.20.10#820010)