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 2017/11/03 17:11:26 UTC
[03/21] flink git commit: [hotfix] [tests] Remove console poluting
output in tests of flink-streaming-java
[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 <se...@apache.org>
Authored: Fri Nov 3 11:28:18 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
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();