I found that when flink application start,the number of slots request is SUM(Maximum parallelism of each task), but when the application is running, the number of slots request is JobManager(1) + Maximum parallelism of all task. For example if there are three tasks, the parallelism of task1(source/map) is 2, the parallelism of task2(keyby/window/apply) is 2, […]