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)