[ 
https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408828#comment-17408828
 ] 

Timo Walther commented on FLINK-24054:
--------------------------------------

[~ykt836] sorry, I saw you comment to late. I just marked it as a blocker to 
fix it in this release that also introduced the SinkUpsertMaterializer. In the 
end, as you can see in the PR, the changes required were minimal.

> Let SinkUpsertMaterializer emit +U instead of only +I
> -----------------------------------------------------
>
>                 Key: FLINK-24054
>                 URL: https://issues.apache.org/jira/browse/FLINK-24054
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Runtime
>            Reporter: Timo Walther
>            Assignee: Timo Walther
>            Priority: Blocker
>              Labels: pull-request-available
>             Fix For: 1.14.0
>
>
> Currently, {{SinkUpsertMaterializer}} is not able to emit +U's but will 
> always emit +I's. Thus, resulting changelogs are incorrect strictly speaking 
> and only valid when treating +U and +I as similar changes in downstream 
> operators.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to