Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
None
-
None
Description
Currently, there is no flushing of KPL outstanding records on checkpoints in the FlinkKinesisProducer. Likewise to the at-least-once issue on the Flink Kafka producer before, this may lead to data loss if there are asynchronous failing records after a checkpoint which the records was part of was completed.
Attachments
Issue Links
- is cloned by
-
FLINK-7931 FlinkKinesisProducer violates at-least-once guarantees (1.3 branch)
- Resolved
- links to