- Notifications
You must be signed in to change notification settings - Fork13.8k
Commitb6f0eb6
authored
[FLINK-38622][runtime] Enhance the requests and slots balanced allocation logic in DefaultScheduler (#27189)
- Introduce ResourceRequestPreMappings to compute the resource matching relationships when allocating all slots in bulk for balanced scheduling of streaming jobs in the default scheduler.- Introduce the test cases for ResourceRequestPreMappings.- Adapt the calculation logic of the TasksBalancedRequestSlotMatchingStrategy for bulk slot allocation using ResourceRequestPreMappings, in order to prevent job scheduling timeouts caused by untimely updates to the relationships between all requests and resources in load-balancing scenarios- Introduce TasksBalancedRequestSlotMatchingStrategyTest for enhancing the TasksBalancedRequestSlotMatchingStrategy testing.1 parenteeefb8b commitb6f0eb6
File tree
5 files changed
+970
-42
lines changed- flink-runtime/src
- main/java/org/apache/flink/runtime/jobmaster/slotpool
- test/java/org/apache/flink/runtime/jobmaster/slotpool
5 files changed
+970
-42
lines changed0 commit comments
Comments
(0)