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 <vinay18.pa...@gmail.com> 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 ? > > Regards, > Vinay Patil >
