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.---
