Weihua Hu created FLINK-31842: --------------------------------- Summary: calculate task executor's utilization only when used Key: FLINK-31842 URL: https://issues.apache.org/jira/browse/FLINK-31842 Project: Flink Issue Type: Sub-task Components: Runtime / Coordination Reporter: Weihua Hu
Currently DefaultAllocatedSlotPool#getFreeSlotsInformation always calculates the taskExecutorUtilization. This causes task schedules to be too slow when there are lots of slots, such as 20000 slots total. But only the EvenlySpreadOutLocationPreferenceSlotSelectionStrategy uses this utilization. So I would like to move the calculation of taskExecutorUtilization to usage. DefaultAllocatedSlotPool provides a function: getTaskExecutorUtilization, and is only used in EvenlySpreadOutLocationPreferenceSlotSelectionStrategy. -- This message was sent by Atlassian Jira (v8.20.10#820010)