[
https://issues.apache.org/jira/browse/FLINK-23895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-23895.
--------------------------------
Fix Version/s: 1.13.3
Release Note: The 1.13.3 release aims to fix various primary key issues
that effectively made it impossible to use this feature. The change might
affect savepoint backwards compatibility for those incorrect pipelines. Also
the resulting changelog stream might be different after these changes.
Pipelines that were correct before should be restorable from a savepoint.
Resolution: Fixed
Since primary keys were effectively broken for `toChangelogMode` and sink
using`DataStreamSinkProvider`, we decided to also backport this change to the
1.13.3 branch. See also FLINK-20374.
> Upsert materializer is not inserted for all sink providers
> ----------------------------------------------------------
>
> Key: FLINK-23895
> URL: https://issues.apache.org/jira/browse/FLINK-23895
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Reporter: Timo Walther
> Assignee: Timo Walther
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.13.3, 1.15.0, 1.14.0
>
>
> The new {{SinkUpsertMaterializer}} is not inserted for
> {{TransformationSinkProvider}} or {{DataStreamSinkProvider}} which means that
> neither {{toChangelogStream}} nor the current {{KafkaDynamicSink}} work
> correctly.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
