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

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

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.