Hi,Albert
I think that the futures may be lost if the machine is down for some reasons. 
So simply using the futures may not be acceptable in production. 
I hope this is helpful. 
Thanks
> 在 2016年9月16日,下午3:01,alghimo <albert.gimenez.mora...@gmail.com> 写道:
> 
> Hi Timo,
> 
> Thank you for the fast reply :) I will check and follow the discussion, it
> would be really cool to be able to have that feature.
> 
> As for the updates, there I'm using Futures which update accumulators on
> success / failure, and everything seems to be working fine, I tested both in
> local mode and deploying in YARN with multiple task managers, although they
> were all running on the same machine. But this update job has no sinks,
> maybe that's why it's working.
> 
> Thanks again!
> 
> Cheers,
> 
> Albert
> 
> 
> 
> --
> View this message in context: 
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DataStream-of-Future-tp13536p13539.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at 
> Nabble.com.

Reply via email to