Ming Li created FLINK-32001:
-------------------------------

             Summary: SupportsRowLevelUpdate does not support returning only a 
part of the columns.
                 Key: FLINK-32001
                 URL: https://issues.apache.org/jira/browse/FLINK-32001
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Runtime
    Affects Versions: 1.17.0
            Reporter: Ming Li


[FLIP-282|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235838061]
 introduces the new Delete and Update API in Flink SQL. Although it is 
described in the documentation that in case of {{partial-update}} we only need 
to return the primary key columns and the updated columns.

But in fact, the topology of the jobĀ  is {{{}source -> cal -> 
constraintEnforcer -> sink{}}}, and the constraint check will be performed in 
the operator of {{{}constraintEnforcer{}}}, which is done according to index, 
not according to column. If only some columns are returned, the constraint 
check is wrong, and it is easy to generate 
{{{}ArrayIndexOutOfBoundsException{}}}.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to