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 2016/10/05 22:17:07 UTC
[17/17] flink git commit: [hotfix] [tests] Remove leftover sysout
logging code
[hotfix] [tests] Remove leftover sysout logging code
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/417c5a4b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/417c5a4b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/417c5a4b
Branch: refs/heads/master
Commit: 417c5a4b429eb8766ff582d424a64a1cd6aa54d3
Parents: 4fc54e3
Author: Stephan Ewen <se...@apache.org>
Authored: Wed Oct 5 20:10:13 2016 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Wed Oct 5 20:31:56 2016 +0200
----------------------------------------------------------------------
.../streaming/runtime/operators/windowing/WindowOperatorTest.java | 3 ---
1 file changed, 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/417c5a4b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
index cda6524..ba803e3 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
@@ -837,9 +837,6 @@ public class WindowOperatorTest extends TestLogger {
expectedOutput.add(new StreamRecord<>(new Tuple2<>("key1", 4), Long.MAX_VALUE));
expectedOutput.add(new StreamRecord<>(new Tuple2<>("key2", 4), Long.MAX_VALUE));
- System.out.println("BEFORE GOT: " + outputBeforeClose);
- System.out.println("GOT: " + testHarness.getOutput());
-
TestHarnessUtil.assertOutputEqualsSorted("Output was not correct.", expectedOutput, Iterables.concat(outputBeforeClose, testHarness.getOutput()), new Tuple2ResultSortComparator());
testHarness.close();