Hi all, In the documentation I read about UDF accumulators [1] "Accumulators are automatically backup-ed by Flinkās checkpointing mechanism and restored in case of a failure to ensure exactly-once semantics." So I assumed this also was the case of accumulators used in the DataStream API, but I noticed that it isn't. So every time my jobs crashes and restarts, the accumulator is reset. Is there a way to retain this information?
Thanks, Wouter [1]. https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/udfs.html