[FLINK-23553] Trigger global failover for synchronous savepoints on CheckpointCoordinator

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.11.3, 1.13.1, 1.12.4
• Component/s: Runtime / Checkpointing
• Assignee: Unassigned
• Reporter: Dawid Wysakowicz
• Created: 30/Jul/21 06:13
• Updated: 11/Aug/21 09:47
• Resolved: 11/Aug/21 08:24

Description

We should trigger a global job failover in case of a stop-with-savepoint --drain fails.

The situation is obvious in case of the with drain mode. If a savepoint fails we simply can not continue as we have already flushed all data and prepared the state for finishing. We can not simply continue processing records.

It is more debatable for without drain mode, where we could theoretically continue processing records, however, it is also a good approach to unify the two modes.

This task is about triggering the failover on the CheckpointCoordinator. We should make sure that if a synchronous checkpoint has been triggered there will be no newere checkpoints scheduled.

If a synchronous savepoint fails for whatever reason we should trigger a global failover for the job.

We might add a safety guards (checkState calls for situations we missed on the Task in a follow-up ticket)

Issue Links

• is related to: FLINK-23606 Add safety guards in StreamTask(s) if a global failover for a synchronous savepoint should've happen