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.


---

Reply via email to