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.
View this message in context:
Sent from the Apache Flink Mailing List archive. mailing list archive at