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, Vina
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 ?
Reg
