Till Rohrmann created FLINK-10506:
-------------------------------------
Summary: Introduce minimum, target and maximum parallelism to
JobGraph
Key: FLINK-10506
URL: https://issues.apache.org/jira/browse/FLINK-10506
Project: Flink
Issue Type: Sub-task
Components: JobManager
Affects Versions: 1.7.0
Reporter: Till Rohrmann
Fix For: 1.7.0
In order to run a job with a variable parallelism, one needs to be able to
define the minimum and maximum parallelism for an operator as well as the
current target value. In the first implementation, minimum could be 1 and
maximum the max parallelism of the operator if no explicit parallelism has been
specified for an operator. If a parallelism p has been specified (via
setParallelism(p)), then minimum = maximum = p. The target value could be the
command line parameter -p or the default parallelism.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
