checkpointing interval ~= transactions are being committed on each Flink checkpoint So, if i set my checkpoint interval to 10000ms, every 10000ms there will be a commit, right? If I understoop correctly, TwoPhaseCommitSinkFunction stores transactions into it's state as for GenericWriteAheadSink it stores events which are then commited on completed?
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/