Re: define no. of nodes via source code

2016-03-21 Thread Till Rohrmann
Hi Subash, you can use ExecutionEnvironment env = ...; env.setParallelism(dop) for that. Cheers, Till ​ On Mon, Mar 21, 2016 at 3:42 PM, subash basnet wrote: > Hello all, > > Using the flink-webclient we have the options to define no. of parallelism > and the same no. i.e. taskmanager.numberO

define no. of nodes via source code

2016-03-21 Thread subash basnet
Hello all, Using the flink-webclient we have the options to define no. of parallelism and the same no. i.e. taskmanager.numberOfTaskSlots is given in flink-conf.yaml. But, where can I define this no. of parallel task when running the examples from IDE. Best Regards, Subash Basnet