Jark Wu created FLINK-36735:
-------------------------------
Summary: SupportsRowLevelUpdate gives sink only the values of
required columns when specifying RowLevelUpdateInfo#requiredColumns
Key: FLINK-36735
URL: https://issues.apache.org/jira/browse/FLINK-36735
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Jark Wu
Assignee: luoyuxia
Fix For: 1.20.1
When {{RowLevelUpdateInfo#requiredColumns}} is specified to some columns (e.g.,
primary keys), sink function expects to receive the columns values including
both the updated columns and primary key column. But sink function only
receives the values of primary key columns, which makes update impossible
without the updated columns.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)