From d5c55d2a73fdbcc0dfadd05ad87203ca70d64eac Mon Sep 17 00:00:00 2001
From: Matrix42 <934336389@qq.com>
Date: Tue, 19 Dec 2017 16:20:39 +0800
Subject: [PATCH] [FLINK-8292] Remove unnecessary force cast in
 DataStreamSource

---
 .../flink/streaming/api/datastream/DataStreamSource.java       | 3 ++-
 1 file changed, 2 insertions(+), 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 b8e71bc90adf7..d762dd7b06306 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 DataStreamSource<T> setParallelism(int parallelism) {
 		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;
 		}
 	}
 }