[FLINK-8257] Unify the value checks for setParallelism()

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Component/s: Runtime / Configuration
• Assignee: Xingcan Cui
• Reporter: Xingcan Cui
• Created: 14/Dec/17 02:37
• Updated: 02/Jan/18 15:28
• Resolved: 02/Jan/18 14:22

Description

The setParallelism() method exist in many components from different levels. Some of the methods require the input value to be greater than 1 (e.g., StreamTransformation.setParallelism()), while some of them also allow the value to be ExecutionConfig.PARALLELISM_DEFAULT, which is -1 by default (e.g., DataSink.setParallelism()). We need to unify the value checks for these methods.

Issue Links

• is related to: FLINK-8236 Allow to set the parallelism of table queries
• links to: GitHub Pull Request #5192