[hotfix] [tests] Remove console poluting output in tests of flink-streaming-java
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c0fa240 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2c0fa240 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2c0fa240 Branch: refs/heads/master Commit: 2c0fa24032502c2ea375d5a9628efc9748bcf9ec Parents: fe931d0 Author: Stephan Ewen <[email protected]> Authored: Fri Nov 3 11:28:18 2017 +0100 Committer: Stephan Ewen <[email protected]> Committed: Fri Nov 3 16:40:34 2017 +0100 ---------------------------------------------------------------------- .../api/functions/sink/TwoPhaseCommitSinkFunctionTest.java | 1 + .../flink/streaming/api/operators/AbstractStreamOperatorTest.java | 2 ++ .../flink/streaming/api/operators/KeyedProcessOperatorTest.java | 2 -- 3 files changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2c0fa240/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java index c004423..63147a0 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java @@ -109,6 +109,7 @@ public class TwoPhaseCommitSinkFunctionTest { * @see #testLogTimeoutAlmostReachedWarningDuringRecovery */ private void setupLogger() { + Logger.getRootLogger().removeAllAppenders(); logger = Logger.getLogger(TwoPhaseCommitSinkFunction.class); testAppender = new AppenderSkeleton() { @Override http://git-wip-us.apache.org/repos/asf/flink/blob/2c0fa240/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java index 847ff13..7262560 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java @@ -45,6 +45,7 @@ import org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness; import org.junit.Test; import org.junit.runner.RunWith; import org.mockito.internal.util.reflection.Whitebox; +import org.powermock.core.classloader.annotations.PowerMockIgnore; import org.powermock.core.classloader.annotations.PrepareForTest; import org.powermock.modules.junit4.PowerMockRunner; @@ -77,6 +78,7 @@ import static org.powermock.api.mockito.PowerMockito.whenNew; */ @RunWith(PowerMockRunner.class) @PrepareForTest(AbstractStreamOperator.class) +@PowerMockIgnore({"java.*", "javax.*", "org.slf4j.*", "org.apache.log4j.*"}) public class AbstractStreamOperatorTest { @Test http://git-wip-us.apache.org/repos/asf/flink/blob/2c0fa240/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java index 3ad8d34..f043fa8 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java @@ -276,8 +276,6 @@ public class KeyedProcessOperatorTest extends TestLogger { expectedOutput.add(new StreamRecord<>("EVENT:1777", 6L)); expectedOutput.add(new Watermark(6)); - System.out.println("GOT: " + testHarness.getOutput()); - TestHarnessUtil.assertOutputEquals("Output was not correct.", expectedOutput, testHarness.getOutput()); testHarness.close();
