[FLINK-29664] Collect subpartition sizes of BLOCKING result partitions

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Done
• Fix Version/s: 1.17.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Lijie Wang
• Reporter: Lijie Wang
• Created: 17/Oct/22 11:47
• Updated: 20/Dec/22 07:13
• Resolved: 20/Dec/22 07:13

Description

In order to divide subpartition range according to the amount of data, the scheduler needs to collect the size of each subpartition produced by upstream tasks.

Issue Links

• links to: GitHub Pull Request #21111