[FLINK-24079] BufferedUpsertSinkFunction can loose records during failover - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Closed
Priority: Major
Resolution: Invalid
Affects Version/s: 1.13.2
Fix Version/s: None
Component/s: Connectors / Kafka, Table SQL / Ecosystem
Labels:
None

Description

The internally used buffer is not snapshotted on checkpoint which can lead to loosing on failure. We need to snapshot the buffer similarly to ~~FLINK-23875~~.

Attachments

Activity

People

Assignee:: Unassigned

Reporter:: Fabian Paul

Votes:: 0 Vote for this issue

Watchers:: 2 Start watching this issue

Dates

Created:: 31/Aug/21 11:28

Updated:: 17/Nov/21 15:21

Resolved:: 31/Aug/21 11:57