[FLINK-7124] Allow to rescale JobGraph on JobManager

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Component/s: Runtime / Coordination
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Till Rohrmann
• Created: 07/Jul/17 07:04
• Updated: 10/Feb/18 22:51
• Resolved: 10/Feb/18 22:50

Description

In order to support dynamic scaling, the JobManager has to be able to change the parallelism of the submitted JobGraph. This basically entails that we can change the parallelism settings on the cluster side.

We already have the functionality that we can change the parallelism if it was set to ExecutionConfig.PARALLELISM_AUTO_MAX. Therefore, I think the task is mostly about making sure that things really properly work when requesting a parallelism change.

Issue Links

• links to: GitHub Pull Request #4510