Hi All, I think I have some missing knowledge about Flink jobs execution, maybe someone could shed some light on it. I am running job that requires 22 TaskSlots as below. However, I have set taskmanager.numberOfTaskSlots: 12, but I see that all Tasks and SubTasks running and even have 5 Available Task Slots. As per my understanding 10 of them should be pending as I don’t have enough slots, what I am missing here in my understanding?

According to the DAG, you have 22 subtasks which translates to 22 threads performing each subtask but multiple threads can share same task slot which results in number of task slots used = maximum number of parallelism of the jobs = 7 https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/concepts/flink-architecture/#task-slots-and-resources