[ https://issues.apache.org/jira/browse/FLINK-24079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Paul closed FLINK-24079. ------------------------------- Resolution: Invalid > BufferedUpsertSinkFunction can loose records during failover > ------------------------------------------------------------ > > Key: FLINK-24079 > URL: https://issues.apache.org/jira/browse/FLINK-24079 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka, Table SQL / Ecosystem > Affects Versions: 1.13.2 > Reporter: Fabian Paul > Priority: Major > > 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. -- This message was sent by Atlassian Jira (v8.3.4#803005)