[FLINK-23895] Upsert materializer is not inserted for all sink providers - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Closed
Priority: Blocker
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 1.14.0, 1.13.3, 1.15.0
Component/s: Table SQL / Planner
Labels:
- pull-request-available

Release Note:

Hide
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.

Show
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.

Description

The new SinkUpsertMaterializer is not inserted for TransformationSinkProvider or DataStreamSinkProvider which means that neither toChangelogStream nor the current KafkaDynamicSink work correctly.

Attachments

Issue Links

Discovered while testing

FLINK-23835 Test upsert sink with upsert keys

Closed

links to

GitHub Pull Request #17060

GitHub Pull Request #17389

Activity

People

Assignee:: Timo Walther

Reporter:: Timo Walther

Votes:: 0 Vote for this issue

Watchers:: 4 Start watching this issue

Dates

Created:: 20/Aug/21 08:43

Updated:: 30/Sep/21 07:17

Resolved:: 30/Sep/21 07:14