Skip to content
Snippets Groups Projects
Commit cd5c8d7b authored by Sean Owen's avatar Sean Owen Committed by Andrew Or
Browse files

SPARK-4704 [CORE] SparkSubmitDriverBootstrap doesn't flush output

Join on output threads to make sure any lingering output from process reaches stdout, stderr before exiting

CC andrewor14 since I believe he created this section of code

Author: Sean Owen <sowen@cloudera.com>

Closes #4788 from srowen/SPARK-4704 and squashes the following commits:

ad7114e [Sean Owen] Join on output threads to make sure any lingering output from process reaches stdout, stderr before exiting
parent 7fa960e6
No related branches found
No related tags found
No related merge requests found
......@@ -17,8 +17,6 @@
package org.apache.spark.deploy
import java.io.File
import scala.collection.JavaConversions._
import org.apache.spark.util.{RedirectThread, Utils}
......@@ -164,6 +162,8 @@ private[spark] object SparkSubmitDriverBootstrapper {
}
}
val returnCode = process.waitFor()
stdoutThread.join()
stderrThread.join()
sys.exit(returnCode)
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment