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
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