[hotfix] [tests] Remove console poluting output in tests of flink-str…

…eaming-java
amuraru · Nov 3, 2017 · 2c0fa24 · 2c0fa24
1 parent fe931d0
commit 2c0fa24
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/...st/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java b/...st/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java
@@ -109,6 +109,7 @@ public void setUp() throws Exception {
  * @see #testLogTimeoutAlmostReachedWarningDuringRecovery
  */
  private void setupLogger() {
+ Logger.getRootLogger().removeAllAppenders();
  logger = Logger.getLogger(TwoPhaseCommitSinkFunction.class);
  testAppender = new AppenderSkeleton() {
  @Override

diff --git a/...va/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java b/...va/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java
@@ -45,6 +45,7 @@
 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 @@
  */
 @RunWith(PowerMockRunner.class)
 @PrepareForTest(AbstractStreamOperator.class)
+@PowerMockIgnore({"java.*", "javax.*", "org.slf4j.*", "org.apache.log4j.*"})
 public class AbstractStreamOperatorTest {
 
  @Test

diff --git a/...java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java b/...java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java
@@ -276,8 +276,6 @@ public void testSnapshotAndRestore() throws Exception {
  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();