[FLINK-7231] SlotSharingGroups are not always released in time for new restarts

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.3.1
• Fix Version/s: 1.3.2, 1.4.0
• Component/s: Runtime / Coordination
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 19/Jul/17 16:15
• Updated: 02/Oct/19 17:44
• Resolved: 08/Nov/17 13:29

Description

In the case where there are not enough resources to schedule the streaming program, a race condition can lead to a sequence of the following errors:

java.lang.IllegalStateException: SlotSharingGroup cannot clear task assignment, group still has allocated resources.

This eventually recovers, but may involve many fast restart attempts before doing so.

The root cause is that slots are not cleared before the next restart attempt.

Issue Links

• links to: GitHub Pull Request #4370