diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-08-13 15:07:03 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-08-13 15:07:03 -0700 |
| commit | a7feb69ae872b39a24aaec3ffde214367240ca0a (patch) | |
| tree | 4df26033ac83ce340a50b7ae5068e182800d59cd /core | |
| parent | 3970b580c206d58189ade3930aca1e478bff8c84 (diff) | |
| download | spark-a7feb69ae872b39a24aaec3ffde214367240ca0a.tar.gz spark-a7feb69ae872b39a24aaec3ffde214367240ca0a.tar.bz2 spark-a7feb69ae872b39a24aaec3ffde214367240ca0a.zip | |
Print run command to stderr rather than stdout
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala | 2 |
1 files changed, 1 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 7423eca11e..a5ea4fe839 100644 --- a/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala +++ b/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala @@ -169,10 +169,10 @@ private[spark] class ExecutorRunner( // Redirect its stdout and stderr to files val stdout = new File(executorDir, "stdout") - Files.write(header, stdout, Charsets.UTF_8) redirectStream(process.getInputStream, stdout) val stderr = new File(executorDir, "stderr") + Files.write(header, stderr, Charsets.UTF_8) redirectStream(process.getErrorStream, stderr) // Wait for it to exit; this is actually a bad thing if it happens, because we expect to run |