Hello Flink expert,

I have a cluster with 10 Task Managers, configured with 6 task slot each,
and a pipeline that has 13 tasks/operators with parallelism of 5. But when
running the pipeline I observer that only  5 slots are being used, the
other 55 slots are available/free. It should use all of my slots, right?
since I have 13 (tasks) x 5 = 65 sub-tasks? What are the configuration that
I missed in order to leverage all of the available slots for my pipelines?

Thanks,
Cam

Reply via email to