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

Stephan Ewen commented on FLINK-13707:
--------------------------------------

Just to double check: You can set the max parallelism explicitly in the 
execution environment.

Are you looking for a way to define a cluster-wide default?

> Make  max parallelism configurable
> ----------------------------------
>
>                 Key: FLINK-13707
>                 URL: https://issues.apache.org/jira/browse/FLINK-13707
>             Project: Flink
>          Issue Type: New Feature
>          Components: API / DataStream
>            Reporter: xuekang
>            Priority: Minor
>
> For now, if a user set parallelism larger than 128, and does not set max 
> parallelism explicitly, the system will compute a max parallelism, which is 
> 1.5 * parallelism.  When the job changes the parallelism and recover from a 
> savepoint, there may be some problem when restoring states from the 
> savepoint, as the number of key groups changed.
> To avoid this problem, and trying not to modify the code of existing jobs,  
> we want to configure the default max parallelism in flink-conf.yaml, but it 
> is not configurable now.
> Should we make it configurable? Any comments would be appreciated.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to