[FLINK-9912] Release TaskExecutors from SlotPool if all slots have been removed

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.1, 1.6.0
• Fix Version/s: 1.7.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 22/Jul/18 21:12
• Updated: 17/Sep/18 13:54
• Resolved: 17/Sep/18 13:53

Description

Currently, it is possible to fail slot allocations in the SlotPool. Failing an allocation means that the slot is removed from the SlotPool. If we have removed all slots from a TaskExecutor, then we should also release/close the connection to this TaskExecutor. At the moment, this only happens via the heartbeats if the TaskExecutor has become unreachable.

Issue Links

• links to: GitHub Pull Request #6394
• links to: GitHub Pull Request #6394