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.
