flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Paris Carbone <par...@kth.se>
Subject Re: Consistency guarantees on multiple sinks
Date Thu, 05 Jan 2017 13:47:44 GMT
Hi Nancy,

Flinkā€™s vanilla rollback recovery mechanism restarts computation from a global checkpoint
thus sink duplicates (job output) can occur no matter how many sinks are declared;  the whole
computation in the failed execution graph will roll back.

cheers
Paris


> On 5 Jan 2017, at 14:24, Nancy Estrada <nancy.a.estrada@gmail.com> wrote:
> 
> Hi,
> 
> If in a Job there is more than one sink declared, what happens when a
> failure occurs? all the sink operations get aborted? (atomically as in a
> transactional environment), or the exactly-once-processing consistency
> guarantees are provided just when one sink is declared per job? Is it
> recommended to have more than one sink per job?
> 
> Thank you!
> Nancy Estrada
> 
> 
> 
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Consistency-guarantees-on-multiple-sinks-tp10877.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message