[
https://issues.apache.org/jira/browse/FLINK-36998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928230#comment-17928230
]
lincoln lee commented on FLINK-36998:
-------------------------------------
Fixed in 2.0: bbfbe33f6bc265af3264774bc4600b850af17661
> 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
> Assignee: xuyang
> Priority: Minor
> Labels: pull-request-available
>
> 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)
