[FLINK-4201] Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Runtime / State Backends
• Assignee: Ufuk Celebi
• Reporter: Stefan Richter
• Created: 12/Jul/16 13:56
• Updated: 22/Jul/16 12:28
• Resolved: 22/Jul/16 12:27

Description

For example, when shutting down a Yarn session, according to the logs checkpoints for jobs that did not terminate are deleted. In the shutdown hook, removeAllCheckpoints is called and removes checkpoints that should still be kept.

Issue Links

• links to: GitHub Pull Request #2276