You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "刘方奇 (Jira)" <ji...@apache.org> on 2022/03/04 09:43:00 UTC

[jira] [Updated] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

     [ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

刘方奇 updated FLINK-26490:
------------------------
    Component/s: Runtime / State Backends

> Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.
> ------------------------------------------------------------------------------
>
>                 Key: FLINK-26490
>                 URL: https://issues.apache.org/jira/browse/FLINK-26490
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / State Backends
>            Reporter: 刘方奇
>            Priority: Major
>
> Since Flink introduce key group and MaxParallelism, Flink can rescale with less cost.
> But when we want to update the job parallelism bigger than the MaxParallelism, it 's impossible cause there are so many MaxParallelism check that require new parallelism should not bigger than MaxParallelism. 
> Actually, when an operator which don't contain keyed state, there should be no problem when update the parallelism bigger than the MaxParallelism,, cause only keyed state need MaxParallelism and key group.
> So should we remove this check or auto adjust the MaxParallelism when we restore an operator state that don't contain keyed state?
> It can make job restore from checkpoint easier.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)