diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-08-04 16:55:18 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-08-09 11:53:32 -0700 |
| commit | 3970b580c206d58189ade3930aca1e478bff8c84 (patch) | |
| tree | d9a3f11f9585089985d7c6f33432d56f2f06272a | |
| parent | f3660d5ab8d3f3b48dda60dc7daf02affd5cc664 (diff) | |
| download | spark-3970b580c206d58189ade3930aca1e478bff8c84.tar.gz spark-3970b580c206d58189ade3930aca1e478bff8c84.tar.bz2 spark-3970b580c206d58189ade3930aca1e478bff8c84.zip | |
Using quotes when printing out command
| -rw-r--r-- | core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala b/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala index 88c5b5bbd6..7423eca11e 100644 --- a/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala +++ b/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala @@ -164,7 +164,8 @@ private[spark] class ExecutorRunner( env.put("SPARK_LAUNCH_WITH_SCALA", "0") process = builder.start() - val header = "Spark Executor Command: %s\n%s\n\n".format(command.mkString(" "), "=" * 40) + val header = "Spark Executor Command: %s\n%s\n\n".format( + command.mkString("\"", "\" \"", "\""), "=" * 40) // Redirect its stdout and stderr to files val stdout = new File(executorDir, "stdout") |