flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nragon <nuno.goncal...@wedotechnologies.com>
Subject Re: Sink buffering
Date Wed, 04 Oct 2017 10:45:27 GMT
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/

Mime
View raw message