[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 <[email protected]> Authored: Tue Dec 19 16:20:39 2017 +0800 Committer: zentol <[email protected]> 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; } } }
