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

Reply via email to