Fixing SparkLauncherSuite unit test

apache · Jun 14, 2017 · 81fd297 · 81fd297
1 parent d906072
commit 81fd297
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/core/src/test/java/org/apache/spark/launcher/SparkLauncherSuite.java b/core/src/test/java/org/apache/spark/launcher/SparkLauncherSuite.java
@@ -211,7 +211,7 @@ public static class SparkLauncherTestApp {
 
     public static void main(String[] args) throws Exception {
       assertEquals(1, args.length);
-      if("proc".equalsIgnoreCase(args[0])) {
+      if ("proc".equalsIgnoreCase(args[0])) {
         assertEquals("proc", args[0]);
         assertEquals("bar", System.getProperty("foo"));
       } else {

diff --git a/launcher/src/main/java/org/apache/spark/launcher/ChildThreadAppHandle.java b/launcher/src/main/java/org/apache/spark/launcher/ChildThreadAppHandle.java
@@ -53,8 +53,8 @@ void setChildThread(Thread childThread) {
   }
 
   protected void waitFor() throws InterruptedException {
-    if(this.childThread.isAlive()) {
-      this.childThread.wait();
+    if (this.childThread.isAlive()) {
+      this.childThread.join();
     }
   }
 }