Hello Everyone, Can someone help me with a solution?
I have a flink job(2 task-managers) with a job parallelism of 64 and task slot of 64. I have a parallelism set for one of the operators as 16. This operator(16 parallelism) slots are not getting evenly distributed across two task managers. It often takes higher task slots like 10/11 in one task manager and 5/6 in other task manager. I'am using flink version 1.11.2. I tried adding cluster.evenly-spread-out-slots: true but it didn't work. Any solution is greatly appreciated. Thanks in advance, Regards, Vignesh
