Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/6075 Hi @zhangminglei , The main reason to implement the `CheckpointedFuntion ` is you have kept a buffer in you Writer class. The buffer is a memory buffer which will suffer data loss during job failover.
---