[hotfix] [tests] Remove leftover sysout logging from AccumulatingAlignedProcessingTimeWindowOperatorTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1825e3a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c1825e3a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c1825e3a Branch: refs/heads/master Commit: c1825e3aaf27ad5270eb5b9120df6d28b54578f1 Parents: 14e5ecb Author: Stephan Ewen <[email protected]> Authored: Mon Oct 10 12:19:37 2016 +0200 Committer: Stephan Ewen <[email protected]> Committed: Mon Oct 10 12:19:37 2016 +0200 ---------------------------------------------------------------------- .../AccumulatingAlignedProcessingTimeWindowOperatorTest.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c1825e3a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingAlignedProcessingTimeWindowOperatorTest.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingAlignedProcessingTimeWindowOperatorTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingAlignedProcessingTimeWindowOperatorTest.java index c82392a..8a3d919 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingAlignedProcessingTimeWindowOperatorTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingAlignedProcessingTimeWindowOperatorTest.java @@ -521,7 +521,6 @@ public class AccumulatingAlignedProcessingTimeWindowOperatorTest { } // draw a snapshot and dispose the window - System.out.println("GOT: " + testHarness.getOutput()); int beforeSnapShot = testHarness.getOutput().size(); StreamStateHandle state = testHarness.snapshot(1L, System.currentTimeMillis()); List<Integer> resultAtSnapshot = extractFromStreamRecords(testHarness.getOutput());
