You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Zach Cox <zc...@gmail.com> on 2016/03/15 17:27:29 UTC

Accumulators checkpointed?

Are accumulators stored in checkpoint state? If a job fails and restarts,
are all accumulator values lost, or are they restored from checkpointed
state?

Thanks,
Zach

Re: Accumulators checkpointed?

Posted by Fabian Hueske <fh...@gmail.com>.

Hi Zach,

at the moment, accumulators are not checkpointed and reset if if a failed
task is restarted.

Best, Fabian

2016-03-15 17:27 GMT+01:00 Zach Cox <zc...@gmail.com>:

> Are accumulators stored in checkpoint state? If a job fails and restarts,
> are all accumulator values lost, or are they restored from checkpointed
> state?
>
> Thanks,
> Zach
>
>