You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/08/11 13:14:21 UTC
[3/4] flink git commit: [FLINK-2500] [streaming] Code cleanup in
DataStream
[FLINK-2500] [streaming] Code cleanup in DataStream
This closes #1001
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b42fbf7a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b42fbf7a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b42fbf7a
Branch: refs/heads/master
Commit: b42fbf7a81c5b57dcf9760825edb175ffd944fb2
Parents: 5bb855b
Author: HuangWHWHW <40...@qq.com>
Authored: Sat Aug 8 14:46:46 2015 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Aug 11 12:08:54 2015 +0200
----------------------------------------------------------------------
.../apache/flink/streaming/api/datastream/DataStream.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b42fbf7a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index 5bd3fb8..10ed5e3 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -151,10 +151,10 @@ public class DataStream<OUT> {
this.iterationWaitTime = dataStream.iterationWaitTime;
this.unionedStreams = new ArrayList<DataStream<OUT>>();
this.unionedStreams.add(this);
- if (dataStream.unionedStreams.size() > 1) {
- for (int i = 1; i < dataStream.unionedStreams.size(); i++) {
- this.unionedStreams.add(new DataStream<OUT>(dataStream.unionedStreams.get(i)));
- }
+
+ int size = dataStream.unionedStreams.size();
+ for (int i = 1; i < size; i++) {
+ this.unionedStreams.add(new DataStream<OUT>(dataStream.unionedStreams.get(i)));
}
}