[FLINK-16664][stream] fix wrong check for DataStreamSource#setParalle…

…lism() This closes apache#11446.
deepfield · Mar 19, 2020 · a56738f · a56738f
1 parent 6aa4a3f
commit a56738f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...eaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java b/...eaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java
@@ -52,7 +52,7 @@ public DataStreamSource(SingleOutputStreamOperator<T> operator) {
 
  @Override
  public DataStreamSource<T> setParallelism(int parallelism) {
- OperatorValidationUtils.validateMaxParallelism(parallelism, isParallel);
+ OperatorValidationUtils.validateParallelism(parallelism, isParallel);
  super.setParallelism(parallelism);
  return this;
  }