[FLINK-2480][streaming]restore the system.out

apache · Aug 25, 2015 · c26ae02 · c26ae02
1 parent 702b4b1
commit c26ae02
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/...ng-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java b/...ng-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java
@@ -40,11 +40,10 @@
 
 import static org.junit.Assert.*;
 
+import org.junit.After;
 import org.junit.Test;
 
-import java.io.IOException;
-import java.io.OutputStream;
-import java.io.PrintStream;
+import java.io.*;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.Future;
@@ -264,4 +263,10 @@ public void testPrintSinkStdErr(){
 	public void invoke(IN record) {
 
 	}
+
+	@After
+	public void restoreSystemOut() {
+		System.setOut(new PrintStream(new FileOutputStream(FileDescriptor.out)));
+	}
+
 }