Hi, Is there a chance of data loss if there is a failure between the checkpoint completion and when "notifyCheckpointComplete" is invoked.
The pending files are moved to final state in the "notifyCheckpointComplete" method. So if there is a failure in this method or just before the method is invoked the data in the pending files is lost, am I missing something ? Thanks, Prabhu -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/RollingSink-question-on-a-failure-scenario-tp7735.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
