Re: About cluster.evenly-spread-out-slots

2023-07-20 Thread Shammon FY
rt and this limits this > source task to execute only at one task manager which we want to avoid and > want to scale it across task managers. > > > > Rgds, > > Kamal > > > > *From:* Shammon FY > *Sent:* 21 July 2023 07:41 AM > *To:* Kamal Mittal

RE: About cluster.evenly-spread-out-slots

2023-07-20 Thread Kamal Mittal via user
:41 AM To: Kamal Mittal Cc: user@flink.apache.org Subject: Re: About cluster.evenly-spread-out-slots Hi Kamal, Even if `cluster.evenly-spread-out-slots` is set to true, Flink will not guarantee that same operator multiple tasks are never executed/scheduled on the same task manager, it just means

Re: About cluster.evenly-spread-out-slots

2023-07-20 Thread Shammon FY
Hi Kamal, Even if `cluster.evenly-spread-out-slots` is set to true, Flink will not guarantee that same operator multiple tasks are never executed/scheduled on the same task manager, it just means Flink will use `LeastUtilizationSlotMatchingStrategy` to find the matching slot for the task. As we k

About cluster.evenly-spread-out-slots

2023-07-20 Thread Kamal Mittal via user
Hello, If property "cluster.evenly-spread-out-slots" is set to TRUE then Flink guarantees that same operator multiple tasks are never executed/scheduled on same task manager? Definitely this will depend upon parallelism value used for an operator and no. of task slots available. Like in below