flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jörn Franke <jornfra...@gmail.com>
Subject Re: How does setMaxParallelism work
Date Wed, 28 Mar 2018 06:59:01 GMT
What was the input format, the size and the program that you tried to execute

> On 28. Mar 2018, at 08:18, Data Engineer <dataengineer21@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

Mime
View raw message