You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gy...@apache.org on 2015/03/20 13:41:42 UTC
[10/10] flink git commit: [FLINK-1715] [streaming] Removed
unnecessary print messages
[FLINK-1715] [streaming] Removed unnecessary print messages
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ac888b23
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ac888b23
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ac888b23
Branch: refs/heads/master
Commit: ac888b239936d146b1109eca8b9a193458cdaf9f
Parents: 1377ca9
Author: Gyula Fora <gy...@apache.org>
Authored: Fri Mar 20 12:27:48 2015 +0100
Committer: Gyula Fora <gy...@apache.org>
Committed: Fri Mar 20 12:27:48 2015 +0100
----------------------------------------------------------------------
.../apache/flink/streaming/api/datastream/GroupedDataStream.java | 1 -
.../streaming/api/windowing/policy/MultiEvictionPolicy.java | 2 --
.../apache/flink/streaming/api/collector/DirectedOutputTest.java | 4 ++--
3 files changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ac888b23/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
index e3c22da..b565931 100755
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
@@ -223,7 +223,6 @@ public class GroupedDataStream<OUT> extends DataStream<OUT> {
@Override
protected DataStream<OUT> setConnectionType(StreamPartitioner<OUT> partitioner) {
- System.out.println("Setting the partitioning after groupBy can affect the grouping");
return super.setConnectionType(partitioner);
}
http://git-wip-us.apache.org/repos/asf/flink/blob/ac888b23/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/MultiEvictionPolicy.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/MultiEvictionPolicy.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/MultiEvictionPolicy.java
index d353dc8..0ad1605 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/MultiEvictionPolicy.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/MultiEvictionPolicy.java
@@ -148,10 +148,8 @@ public class MultiEvictionPolicy<DATA> implements ActiveEvictionPolicy<DATA> {
case SUM:
result = 0;
for (Integer item : items) {
- System.out.print(item+":");
result += item;
}
- System.out.println(result);
return result;
case PRIORITY:
http://git-wip-us.apache.org/repos/asf/flink/blob/ac888b23/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/collector/DirectedOutputTest.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/collector/DirectedOutputTest.java b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/collector/DirectedOutputTest.java
index 13bf457..62872fd 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/collector/DirectedOutputTest.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/collector/DirectedOutputTest.java
@@ -114,7 +114,7 @@ public class DirectedOutputTest {
assertEquals(Arrays.asList(2L, 4L, 6L, 8L, 10L), evenSink.getSortedResult());
assertEquals(Arrays.asList(1L, 3L, 5L, 7L, 9L, 10L, 11L), oddAndTenSink.getSortedResult());
assertEquals(Arrays.asList(1L, 2L, 3L, 4L, 5L, 6L, 7L, 8L, 9L, 10L, 11L),
- evenAndOddSink.getResult());
- assertEquals(Arrays.asList(1L, 2L, 3L, 4L, 5L, 6L, 7L, 8L, 9L, 10L, 11L), allSink.getResult());
+ evenAndOddSink.getSortedResult());
+ assertEquals(Arrays.asList(1L, 2L, 3L, 4L, 5L, 6L, 7L, 8L, 9L, 10L, 11L), allSink.getSortedResult());
}
}