[FLINK-16664] Unable to set DataStreamSource parallelism to default (-1)

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.1, 1.11.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Nico Kruber
• Reporter: Nico Kruber
• Created: 18/Mar/20 23:25
• Updated: 19/Mar/20 11:49
• Resolved: 19/Mar/20 11:49

Description

A hotfix part of FLINK-14405 actually breaks setting the parallelism to its default value for datastream sources, i.e. using value -1. This is because of a small typo: instead of

OperatorValidationUtils.validateParallelism(parallelism, isParallel);  

this is called in org.apache.flink.streaming.api.datastream.DataStreamSource#setParallelism:

OperatorValidationUtils.validateMaxParallelism(parallelism, isParallel); 

Issue Links

• links to: GitHub Pull Request #11446