Hi Bernd,

Did you change 'state.checkpoints.num-retained’ in flink-conf.yaml? By default, 
only one checkpoint should be retained.

Which version of Flink do you use?
Can you check Job Master logs whether you see there warning like this:
`Fail to subsume the old checkpoint`?

Best,
Andrey

> On 29 Nov 2018, at 10:18, Kostas Kloudas <k.klou...@data-artisans.com> wrote:
> 
> Hi Bernd,
> 
> I think the Till, Stefan or Stephan (cc'ed) are the best to answer your 
> question.
> 
> Cheers,
> Kostas

Reply via email to