You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/01/08 19:22:08 UTC
[2/9] flink git commit: [FLINK-8292] Remove unnecessary force cast in
DataStreamSource
[FLINK-8292] Remove unnecessary force cast in DataStreamSource
This closes #5180.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3cdc5d1d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3cdc5d1d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3cdc5d1d
Branch: refs/heads/master
Commit: 3cdc5d1dce7c8cf0db0352d86867f73f6ccd9be9
Parents: 7c2a32c
Author: Matrix42 <93...@qq.com>
Authored: Tue Dec 19 16:20:39 2017 +0800
Committer: zentol <ch...@apache.org>
Committed: Mon Jan 8 17:29:51 2018 +0100
----------------------------------------------------------------------
.../apache/flink/streaming/api/datastream/DataStreamSource.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3cdc5d1d/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java
----------------------------------------------------------------------
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 f5771a8..d08514f 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
@@ -54,7 +54,8 @@ public class DataStreamSource<T> extends SingleOutputStreamOperator<T> {
if (parallelism != 1 && !isParallel) {
throw new IllegalArgumentException("Source: " + transformation.getId() + " is not a parallel source");
} else {
- return (DataStreamSource<T>) super.setParallelism(parallelism);
+ super.setParallelism(parallelism);
+ return this;
}
}
}