Regarding Task Slots allocation

[Vinay Patil]

Hi,

I am trying to deploy a flink job to remote cluster using remoteExecutionEnvironment, I have specified the number of task slots for Task Manager to 2 , so it should have ideally taken 2 slots only, however all the slots are getting utilized. Is there any other configuration I have to do ?

[Till Rohrmann]

Hi Vinay,

try to set the parallelism to 2 for the job you are executing via the RemoteExecutionEnvironment.

Where have you specified the number of TaskManager slots? In the flink-conf.yaml file which you used to deploy the remote Flink cluster?

Cheers,

Till

On Fri, Feb 16, 2018 at 7:14 PM, Vinay Patil <[hidden email]> wrote:

Hi,

I am trying to deploy a flink job to remote cluster using remoteExecutionEnvironment, I have specified the number of task slots for Task Manager to 2 , so it should have ideally taken 2 slots only, however all the slots are getting utilized. Is there any other configuration I have to do ?