Spongebob created FLINK-27969:
---------------------------------
Summary: 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
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.7#820007)
