[jira] [Created] (FLINK-27969) StreamPhysicalOverAggregate doesn't support consuming update and delete changes

["Spongebob (Jira)" <ji...@apache.org>]

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)