[ 
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058942#comment-16058942
 ] 

Fabian Hueske commented on FLINK-6966:
--------------------------------------

{{maxParallelism}} defines the maximum parallelism of an operator and cannot be 
changed after a job has been started (the value is baked into the savepoint). 
If not set, it is the same a the initial parallelism which means it is not 
possible to increase the parallelism of an operator.

The parameter is related to the way how Flink organizes and partitions state 
and defines the number of key-groups.

> Add maxParallelism and UIDs to all operators generated by the Table API / SQL
> -----------------------------------------------------------------------------
>
>                 Key: FLINK-6966
>                 URL: https://issues.apache.org/jira/browse/FLINK-6966
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table API & SQL
>    Affects Versions: 1.4.0
>            Reporter: Fabian Hueske
>
> At the moment, the Table API does not assign UIDs and the max parallelism to 
> operators (except for operators with parallelism 1).
> We should do that to avoid problems when rescaling or restarting jobs from 
> savepoints.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to