[FLINK-9099] Failing allocated slots not noticed

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Fix Version/s: 1.5.0
• Component/s: Runtime / Coordination
• Labels: flip-6
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 27/Mar/18 12:45
• Updated: 28/Mar/18 15:27
• Resolved: 28/Mar/18 15:27

Description

When allocating slots for eager scheduling, it can happen that allocated slots get failed after they are assigned to the Execution (e.g. due to a TaskExecutor heartbeat timeout). If there are still some uncompleted slot futures, then this will not be noticed since the Execution is assigned to the LogicalSlot only after all slot futures are completed. Therefore, the allocated slot failure will go unnoticed until this happens.

In order to speed up failures, we should directly assign the Execution to the LogicalSlot once the slot is assigned to the Execution.

Issue Links

• links to: GitHub Pull Request #5775