In the default configuration, the job uses as many slots as the parallelism of the operators states. I assume you run with a parallelism of 2, so it occupies two slots.
if you run 5 taskmanagers with each one slot, you should set the parallelism to 5 as well. On Mon, Aug 29, 2016 at 4:04 PM, Bhupesh Chawda <bhup...@apache.org> wrote: > Hi, > > I am running Flink on a cluster of 5 nodes. > Here is my config: > > > > *taskmanager.numberOfTaskSlots: 1parallelism.default: 1* > My Flink dashboard shows the following: > > *Task Managers: 5* > > *Task Slots: 5* > > *Available Task Slots: 5* > I have the following questions: > > 1. Why does a job with 8 tasks occupy only 2 task slots (3 slots remain > free as seen from the UI)? As per my understanding, since the number of > Task Slots as shown above is just 5, perhaps this job may not get enough > resources (task slots). > 2. I notice that most of the tasks (operators) in the job run on just > one of the nodes. The other nodes are idle and free. Is there any way to > distribute the tasks among other nodes more evenly? > > Please advice. > > Thanks. > > ~ Bhupesh >
