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

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

刘方奇 created FLINK-26490:
---------------------------

             Summary: 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
            Reporter: 刘方奇


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)