[FLINK-31261] Make AdaptiveScheduler aware of the (local) state size

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.18.0
• Fix Version/s: 2.0-preview
• Component/s: Runtime / Coordination
• Labels: pull-request-available stale-assigned
• Assignee: Roman Khachatryan
• Reporter: Roman Khachatryan
• Created: 28/Feb/23 13:06
• Updated: 02/Sep/24 09:28
• Resolved: 19/Jul/24 09:34

Description

FLINK-21450 makes the Adaptive Schulder aware of Local Recovery.

Each slot-group pair is assigned a score based on a keyGroupRange size.

That score isn't always optimlal - it could be improved by computing the score based on the actual state size on disk.

Issue Links

• is related to: FLINK-21450 Add local recovery support to adaptive scheduler
• links to: GitHub Pull Request #22046