[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711776#comment-17711776 ]
RocMarshal commented on FLINK-31757: ------------------------------------ h1. Problem description and impact Supposed a Job has 21 tasks: * Task A has the parallelism of 100, * The every remained task has the parallelism of 5. Each TM slot = 1, so the tasks in the job need to apply for 100 TMs. h2. Problem Description Assuming that the TM number is 0-99, from the perspective of Task, the actual result after scheduling is: After the job deployed. There are 5 TMs loading with 21 sub-tasks, while other TMs only load a sub-task. h2. Influence If the user allocates resources to TM: All TM resources are applied according to the 5 TMs (loading 21-subtasks), then subsequent TM resources will be wasted. If apply the resources based on other TM(only loading a subtask), the 5 TMs resources are insufficient, tasks running on its may have lag. >From the perspective of resource usage, we expect all subtasks to be evenly >distributed on each TM. > Optimize Flink un-balanced tasks scheduling > ------------------------------------------- > > Key: FLINK-31757 > URL: https://issues.apache.org/jira/browse/FLINK-31757 > Project: Flink > Issue Type: Improvement > Components: Runtime / Task > Reporter: RocMarshal > Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)