[FLINK-4810] Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: vinoyang
• Reporter: Stephan Ewen
• Created: 12/Oct/16 09:17
• Updated: 02/Oct/19 17:45
• Resolved: 15/Jul/19 09:27

Description

The Checkpoint coordinator should track the number of consecutive unsuccessful checkpoints.

If more than n (configured value) checkpoints fail in a row, it should call fail() on the execution graph to trigger a recovery.

The design document is here : https://docs.google.com/document/d/1ce7RtecuTxcVUJlnU44hzcO2Dwq9g4Oyd8_biy94hJc/edit?usp=sharing

Issue Links

• depends upon: FLINK-10724 Refactor failure handling in check point coordinator
• is duplicated by: FLINK-10074 Allowable number of checkpoint failures
• is duplicated by: FLINK-12364 Introduce a CheckpointFailureManager to centralized manage checkpoint failure
• links to: GitHub Pull Request #3334
• links to: GitHub Pull Request #3334