various fixes

stratosphere-compiler/src/main/java/eu/stratosphere/compiler/contextcheck/ContextChecker.java

@@ -16,6 +16,8 @@ package eu.stratosphere.compiler.contextcheck;
 import java.util.HashSet;
 import java.util.Set;
 
+import com.google.common.base.Preconditions;
+
 import eu.stratosphere.api.common.InvalidProgramException;
 import eu.stratosphere.api.common.Plan;
 import eu.stratosphere.api.common.operators.BulkIteration;
@@ -52,9 +54,10 @@ public class ContextChecker implements Visitor<Operator> {
 	 * thrown.
 	 * 
 	 * @param plan
-	 *        The PACT plan to check.
+	 *        The plan to check.
 	 */
 	public void check(Plan plan) {
+		Preconditions.checkNotNull(plan, "The passed plan is null.");
 		this.visitedNodes.clear();
 		plan.accept(this);
 	}

stratosphere-examples/stratosphere-scala-examples/src/main/scala/eu/stratosphere/examples/scala/wordcount/WordCount.scala

@@ -44,6 +44,10 @@ class WordCount extends Program with ProgramDescription with Serializable {
     "Parameters: <numSubStasks> <input> <output>"
   }
   override def getPlan(args: String*) = {
+    if (args.size < 3) {
+      println(getDescription)
+      System.exit(1);
+    }
     getScalaPlan(args(0).toInt, args(1), args(2))
   }
 }

stratosphere-runtime/src/main/java/eu/stratosphere/nephele/jobmanager/JobManager.java

@@ -359,9 +359,12 @@ public class JobManager implements DeploymentManager, ExtendedManagementProtocol
 		
 		// Clean up is triggered through a shutdown hook
 		// freeze this thread to keep the JVM alive (the job manager threads are daemon threads)
-		try {
-			new Object().wait();
-		} catch (InterruptedException e) {}
+		Object w = new Object();
+		synchronized (w) {
+			try {
+				w.wait();
+			} catch (InterruptedException e) {}
+		}
 	}
 	
 	@SuppressWarnings("static-access")

stratosphere-runtime/src/main/java/eu/stratosphere/nephele/taskmanager/TaskManager.java

@@ -556,8 +556,9 @@ public class TaskManager implements TaskOperationProtocol {
 			socket.bind(bindP);
 			socket.connect(toSocket, timeout);
 		} catch (Exception ex) {
+			LOG.info("Failed to determine own IP address from '" + fromAddress + "': " + ex.getMessage());
 			if (LOG.isDebugEnabled()) {
-				LOG.debug("Failed on this address: " + ex.getMessage());
+				LOG.debug("Failed with exception", ex);
 			}
 			connectable = false;
 		} finally {