Reduced test logging verbosity to only print warn messages.

pact/pact-tests/src/test/java/eu/stratosphere/pact/test/util/TestBase.java

@@ -79,7 +79,7 @@ public abstract class TestBase {
 		PatternLayout layout = new PatternLayout("%d{HH:mm:ss,SSS} %-5p %-60c %x - %m%n");
 		ConsoleAppender appender = new ConsoleAppender(layout, "System.err");
 		root.addAppender(appender);
-		root.setLevel(Level.INFO);
+		root.setLevel(Level.WARN);
 	}
 
 	private void verifyJvmOptions() {
@@ -90,13 +90,11 @@ public abstract class TestBase {
 
 	@Before
 	public void startCluster() throws Exception {
-		LOG.info("######################### start - cluster config : " + clusterConfig + " #########################");
 		cluster = ClusterProviderPool.getInstance(clusterConfig);
 	}
 
 	@After
 	public void stopCluster() throws Exception {
-		LOG.info("######################### stop - cluster config : " + clusterConfig + " #########################");
 		cluster.stopCluster();
 		ClusterProviderPool.removeInstance(clusterConfig);
 		FileSystem.closeAll();
@@ -120,6 +118,7 @@ public abstract class TestBase {
 		
 		try {
 			final JobClient client = cluster.getJobClient(jobGraph, getJarFilePath());
+			client.setConsoleStreamForReporting(TestBase2.getNullPrintStream());
 			client.submitJobAndWait();
 		} catch(Exception e) {
 			LOG.error(e);

pact/pact-tests/src/test/java/eu/stratosphere/pact/test/util/TestBase2.java

@@ -21,6 +21,8 @@ import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileReader;
 import java.io.IOException;
+import java.io.OutputStream;
+import java.io.PrintStream;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
@@ -75,7 +77,7 @@ public abstract class TestBase2 {
 		PatternLayout layout = new PatternLayout("%d{HH:mm:ss,SSS} %-5p %-60c %x - %m%n");
 		ConsoleAppender appender = new ConsoleAppender(layout, "System.err");
 		root.addAppender(appender);
-		root.setLevel(Level.INFO);
+		root.setLevel(Level.WARN);
 	}
 	
 
@@ -88,7 +90,6 @@ public abstract class TestBase2 {
 
 	@Before
 	public void startCluster() throws Exception {
-		System.err.println("######################### STARTING LOCAL EXECUTION CONTEXT #########################");
 		this.executer = new NepheleMiniCluster();
 		this.executer.start();
 	}
@@ -97,7 +98,6 @@ public abstract class TestBase2 {
 	public void stopCluster() throws Exception {
 		try {
 			if (this.executer != null) {
-				System.err.println("######################### STOPPING LOCAL EXECUTION CONTEXT #########################");
 				this.executer.stop();
 				this.executer = null;
 				FileSystem.closeAll();
@@ -133,6 +133,7 @@ public abstract class TestBase2 {
 		
 		try {
 			JobClient client = this.executer.getJobClient(jobGraph);
+			client.setConsoleStreamForReporting(getNullPrintStream());
 			client.submitJobAndWait();
 		} catch(Exception e) {
 			System.err.println(e.getMessage());
@@ -449,4 +450,11 @@ public abstract class TestBase2 {
 		Assert.assertEquals("Different number of lines in expected and obtained result.", expected.length, result.length);
 		Assert.assertArrayEquals(expected, result);
 	}
+	
+	public static PrintStream getNullPrintStream() {
+		return new PrintStream(new OutputStream() {
+			@Override
+			public void write(int b) throws IOException {}
+		});
+	}
 }