Hi Ahmed, if you don't set the parallelism in your program then depending on how you execute your program different parallelisms will be used. If you execute it in your IDE, then the number of cores will be used as parallelism. If you submit it to a cluster without specifying the parallelism via the cli, then the default parallelism which you've specified in flink-conf.yaml will be used. If you use the -p option of the cli, then this value will be used as the parallelism.
Cheers, Till On Fri, Mar 18, 2016 at 1:13 PM, Ahmed Nader <ahmednader...@gmail.com> wrote: > Hi, > How can i setParallelism in a generic way that provide better performance > on any device not only mine? In this case is it better to be set to a > certain value or if i just didn't set it to any value does flink take care > of that generically and provide better execution performance? > Thanks. >
