Interval - Yes. TwoPhaseCommitSinkFunction - yes, but it depends how will you implement your “Transaction” class, it wouldn’t make a lot of sense, but you could store events inside the transaction “pojo”.
Piotrek > On Oct 4, 2017, at 12:45 PM, nragon <nuno.goncal...@wedotechnologies.com> > wrote: > > 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/
