[FLINK-25035] Shuffle Service Supports Consuming Subpartition Range

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Done
• Fix Version/s: 1.15.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Lijie Wang
• Reporter: Lijie Wang
• Created: 24/Nov/21 09:09
• Updated: 21/Jun/22 06:35
• Resolved: 27/Jan/22 08:44

Description

In adaptive batch scheduler, the shuffle service needs to support a SingleInputGate to consume  a certain range of subpartitions.

Issue Links

• links to: GitHub Pull Request #18130
• links to: GitHub Pull Request #20032