define no. of nodes via source code

[subashbasnet]

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

[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 <[hidden email]> wrote:

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