diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-08-03 21:30:15 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-08-03 21:30:15 -0700 |
| commit | f3660d5ab8d3f3b48dda60dc7daf02affd5cc664 (patch) | |
| tree | 56a15c2dedf01d1dab1ef83571a82d56d40d6fdf | |
| parent | ad94fbb3221fb50a613cdcaf1c8d8f08b45f4064 (diff) | |
| download | spark-f3660d5ab8d3f3b48dda60dc7daf02affd5cc664.tar.gz spark-f3660d5ab8d3f3b48dda60dc7daf02affd5cc664.tar.bz2 spark-f3660d5ab8d3f3b48dda60dc7daf02affd5cc664.zip | |
Make output formatting consistent between bash/scala
| -rw-r--r-- | core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala | 3 | ||||
| -rwxr-xr-x | run | 2 |
2 files changed, 2 insertions, 3 deletions
diff --git a/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala b/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala index 1dcdf20960..88c5b5bbd6 100644 --- a/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala +++ b/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala @@ -164,8 +164,7 @@ private[spark] class ExecutorRunner( env.put("SPARK_LAUNCH_WITH_SCALA", "0") process = builder.start() - val header = "Spark Executor Command: %s\n======================================\n\n" - .format(command.mkString(" ")) + 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") @@ -168,7 +168,7 @@ fi command="$RUNNER -cp \"$CLASSPATH\" $EXTRA_ARGS $@" if [ "$SPARK_PRINT_LAUNCH_COMMAND" == "1" ]; then echo "Spark Command: $command" - echo "======================================" + echo "========================================" echo fi |