[FLINK-19306] Implement DeclarativeSlotManager

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 21/Sep/20 07:59
• Updated: 16/Oct/20 09:44
• Resolved: 16/Oct/20 09:44

Description

Implement a new SlotManager that works with declarative resource management.

 

The current SlotManager accepts slot requests and attempts to fulfill them. One of the key differences in the new version is that it no longer accepts slot requests, but requirements detailing what the job requires. From these requirements it internally generates slot requests, and proceeds similar to current implementation.

Since we are not writing a new implementation this is also a good opportunity to split the implementation into several components, as it has grown quite large.

Issue Links

• is a parent of: FLINK-19307 Add ResourceTracker
• is a parent of: FLINK-19308 Add SlotTracker
• is a parent of: FLINK-19309 Add TaskExecutorAllocator
• is a parent of: FLINK-19310 Add new TaskManagerSlot implementation
• links to: GitHub Pull Request #13553