Clean up exception logging in JobManagerITCase.

stratosphere-runtime/src/test/java/eu/stratosphere/nephele/jobmanager/JobManagerITCase.java

@@ -39,7 +39,6 @@ import eu.stratosphere.core.fs.Path;
 import eu.stratosphere.nephele.ExecutionMode;
 import eu.stratosphere.nephele.client.JobClient;
 import eu.stratosphere.nephele.client.JobExecutionException;
-import eu.stratosphere.nephele.execution.RuntimeEnvironment;
 import eu.stratosphere.nephele.jobgraph.DistributionPattern;
 import eu.stratosphere.nephele.jobgraph.JobGraph;
 import eu.stratosphere.nephele.jobgraph.JobGraphDefinitionException;
@@ -315,10 +314,11 @@ public class JobManagerITCase {
 			jobClient = new JobClient(jg, configuration);
 			
 			// deactivate logging of expected test exceptions
-			Logger rtLogger = Logger.getLogger(Task.class);
-			rtLogger.setLevel(Level.OFF);
-			Logger envLogger = Logger.getLogger(RuntimeEnvironment.class);
-			envLogger.setLevel(Level.DEBUG);
+			Logger taskLogger = Logger.getLogger(Task.class);
+			taskLogger.setLevel(Level.OFF);
+			
+			Logger jmLogger = Logger.getLogger(JobManager.class);
+			jmLogger.setLevel(Level.OFF);
 			
 			try {
 				jobClient.submitJobAndWait();
@@ -409,8 +409,11 @@ public class JobManagerITCase {
 			
 			// deactivate logging of expected test exceptions
 			Logger jcLogger = Logger.getLogger(JobClient.class);
-			Level jcLevel = jcLogger.getEffectiveLevel();
 			jcLogger.setLevel(Level.OFF);
+			Logger tmLogger = Logger.getLogger(TaskManager.class);
+			tmLogger.setLevel(Level.OFF);
+			
+			
 			try {
 				jobClient.submitJobAndWait();
 			} catch (JobExecutionException e) {
@@ -426,9 +429,6 @@ public class JobManagerITCase {
 				// Check if the correct error message is encapsulated in the exception
 				return;
 			}
-			finally {
-				jcLogger.setLevel(jcLevel);
-			}
 
 			fail("Expected exception but did not receive it");
 
@@ -514,10 +514,13 @@ public class JobManagerITCase {
 			// Create job client and launch job
 			jobClient = new JobClient(jg, configuration);
 
+			// deactivate logging of expected test exceptions
 			// deactivate logging of expected test exceptions
 			Logger jcLogger = Logger.getLogger(JobClient.class);
-			Level jcLevel = jcLogger.getEffectiveLevel();
 			jcLogger.setLevel(Level.OFF);
+			Logger tmLogger = Logger.getLogger(TaskManager.class);
+			tmLogger.setLevel(Level.OFF);
+			
 			try {
 				jobClient.submitJobAndWait();
 			} catch (JobExecutionException e) {
@@ -534,9 +537,6 @@ public class JobManagerITCase {
 				// Check if the correct error message is encapsulated in the exception
 				return;
 			}
-			finally {
-				jcLogger.setLevel(jcLevel);
-			}
 
 			fail("Expected exception but did not receive it");