Hi Vignesh, are you trying to achieve an even distribution of tasks for this one operator that has the parallelism set to 16? Or do you observe the described behavior also on a job level? I'm adding Chesnay to the thread as he might have more insights on this topic.
Best, Matthias On Mon, Mar 22, 2021 at 6:31 PM Vignesh Ramesh <vicki.ram...@gmail.com> wrote: > 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 > >
