[jira] [Created] (FLINK-10506) Introduce minimum, target and maximum parallelism to JobGraph

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-10506) Introduce minimum, target and maximum parallelism to JobGraph

Shang Yuanchun (Jira)
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)