Dawid Wysakowicz created FLINK-37643:
----------------------------------------
Summary: Support partial deletes when converting to external data
structures
Key: FLINK-37643
URL: https://issues.apache.org/jira/browse/FLINK-37643
Project: Flink
Issue Type: Sub-task
Components: Table SQL / Runtime
Reporter: Dawid Wysakowicz
Assignee: Dawid Wysakowicz
Fix For: 2.1.0
I enabled the partial deletes to flow through the dag ending at the sink. The
sink has methods to convert internal data structures (e.g. RowData) to external
(e.g. Row).
As of now the converters don't check for null if the type is marked as `NOT
NULL`, but in case of partial deletes those fields might be null if they're not
part of the upsert key.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
