What was the input format, the size and the program that you tried to execute
> On 28. Mar 2018, at 08:18, Data Engineer <dataenginee...@gmail.com> wrote: > > I went through the explanation on MaxParallelism in the official docs here: > https://ci.apache.org/projects/flink/flink-docs-master/ops/production_ready.html#set-maximum-parallelism-for-operators-explicitly > > However, I am not able to figure out how Flink decides the parallelism value. > For instance, if I setMaxParallelism to 3, I see that for my job, there is > only 1 subtask that is created. How did Flink decide that 1 subtask was > enough? > > Regards, > James
