You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/03/19 11:48:43 UTC
[flink] branch master updated: [FLINK-16664][stream] fix wrong
check for DataStreamSource#setParallelism()
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new a56738f [FLINK-16664][stream] fix wrong check for DataStreamSource#setParallelism()
a56738f is described below
commit a56738fdaf4ebf89784a31fe1317fd4cd97d4de2
Author: Nico Kruber <ni...@ververica.com>
AuthorDate: Thu Mar 19 00:33:47 2020 +0100
[FLINK-16664][stream] fix wrong check for DataStreamSource#setParallelism()
This closes #11446.
---
.../org/apache/flink/streaming/api/datastream/DataStreamSource.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java
index f5fb05f..a6fbac8 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java
@@ -52,7 +52,7 @@ public class DataStreamSource<T> extends SingleOutputStreamOperator<T> {
@Override
public DataStreamSource<T> setParallelism(int parallelism) {
- OperatorValidationUtils.validateMaxParallelism(parallelism, isParallel);
+ OperatorValidationUtils.validateParallelism(parallelism, isParallel);
super.setParallelism(parallelism);
return this;
}