[FLINK-18690] Implement LocalInputPreferredSlotSharingStrategy

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Zhu Zhu
• Reporter: Andrey Zagrebin
• Created: 23/Jul/20 13:17
• Updated: 05/Aug/20 09:26
• Resolved: 05/Aug/20 02:44

Description

Implement ExecutionSlotSharingGroup, SlotSharingStrategy and default LocalInputPreferredSlotSharingStrategy.

The default strategy would be LocalInputPreferredSlotSharingStrategy. It will try to reduce remote data exchanges. Subtasks, which are connected and belong to the same SlotSharingGroup, tend to be put in the same ExecutionSlotSharingGroup.

See design doc

Issue Links

• links to: GitHub Pull Request #13009