提交 b42fbf7a 编写于 作者: H HuangWHWHW 提交者: Stephan Ewen

[FLINK-2500] [streaming] Code cleanup in DataStream

This closes #1001
上级 5bb855ba
......@@ -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)));
}
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册