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/

Reply via email to