[
https://issues.apache.org/jira/browse/FLINK-36998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang updated FLINK-36998:
---------------------------
Summary: The RowKind of data about globalUpsertResult is different in
KeyedUpsertingSinkFunction while being inserted or being restored (was: The
RowKind of data about globalUpsertResult is different in
KeyedUpsertingSinkFunction while being inserted or be restored)
> The RowKind of data about globalUpsertResult is different in
> KeyedUpsertingSinkFunction while being inserted or being restored
> ------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-36998
> URL: https://issues.apache.org/jira/browse/FLINK-36998
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Reporter: xuyang
> Priority: Minor
>
> Take a row data with RowKind +U as an example:
> When inserting this data into sink by #invoke, the row kind is set to +I.
> However when this data is restored from globalRawResult, the row kind is +U.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
