Hi, Could you maybe send a screenshot from the dashboard that shows how tasks are being assigned to slots?
Aljoscha > On 4. Mar 2018, at 18:06, vijayakumar palaniappan <vijayakuma...@gmail.com> > wrote: > > I am using flink 1.4.0 in standalone cluster mode > > I have a job with a graph like a Source(parallelism 3) -> Filter(parallelism > 3) -> Map(parallelism 1) -> sink(parallelism 3) > > As per the understanding, max number of tasks slots should be bounded by the > max parallelism, which in this case is 3. > > The behavior i observe is that, when more than required number of slots(say > 10) are available in cluster, this job uses 5 slots. I attempted setting the > same slotsharinggroup to all streamnodes, but didn't help. > > Is this a change in behavior in 1.4.0?. If so are there any workarounds to > force the old behavior > > > > -- > Thanks, > -Vijay
