-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.10.0
-
Component/s: API / DataStream
-
Labels:
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);
- links to