Re: minPauseBetweenCheckpoints for failed checkpoints

2018-05-15 Thread Timo Walther
Hi Dmitry, I think the minPauseBetweenCheckpoints is intended for pausing between successful checkpoints. Usually a user wants to get a successful checkpoint as quickly as possible again. Stefan (in CC) might know more about. Regards, Timo Am 15.05.18 um 03:28 schrieb Dmitry Minaev: Hello!

minPauseBetweenCheckpoints for failed checkpoints

2018-05-14 Thread Dmitry Minaev
Hello! I have a question regarding checkpointing parameter minPauseBetweenCheckpoints that is the minimal pause between checkpointing attempts. I’ve noticed the following (strange) behavior in Flink. I set the following parameters for a sample Flink job: Checkpointing Mode = Exactly Once Interv