diff options
| author | Matei Zaharia <matei.zaharia@gmail.com> | 2013-08-13 15:31:01 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei.zaharia@gmail.com> | 2013-08-13 15:31:01 -0700 |
| commit | d316af9c84f5d9217bdd92d97b4cd097b430572a (patch) | |
| tree | 17b26229e9504713517a4d58813624591516d059 /core | |
| parent | 1f79d21f33fbdd5e546d219decaed3474f42b10a (diff) | |
| parent | a7feb69ae872b39a24aaec3ffde214367240ca0a (diff) | |
| download | spark-d316af9c84f5d9217bdd92d97b4cd097b430572a.tar.gz spark-d316af9c84f5d9217bdd92d97b4cd097b430572a.tar.bz2 spark-d316af9c84f5d9217bdd92d97b4cd097b430572a.zip | |
Merge pull request #821 from pwendell/print-launch-command
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 4537c8305c..f661accd2f 100644 --- a/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala +++ b/core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala @@ -170,10 +170,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 |