[FLINK-32001] SupportsRowLevelUpdate does not support returning only a part of the columns.

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.17.0
• Fix Version/s: 1.18.0, 1.17.1
• Component/s: Table SQL / Runtime
• Labels: pull-request-available
• Assignee: luoyuxia
• Reporter: Ming Li
• Created: 04/May/23 13:18
• Updated: 19/May/23 08:09
• Resolved: 19/May/23 08:09

Description

FLIP-282 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.

Issue Links

• links to: GitHub Pull Request #22525