diff options
| author | Josh Rosen <rosenville@gmail.com> | 2012-08-10 00:32:23 -0700 |
|---|---|---|
| committer | Josh Rosen <rosenville@gmail.com> | 2012-08-10 00:33:56 -0700 |
| commit | 59c22fb444e7a03e2272be1d76e16960083d161d (patch) | |
| tree | fef2cea8e37aa1caa7680de9b694ae6c2e4512cf /core | |
| parent | bf61c10072931d9b95f980015f2c4556f836e142 (diff) | |
| download | spark-59c22fb444e7a03e2272be1d76e16960083d161d.tar.gz spark-59c22fb444e7a03e2272be1d76e16960083d161d.tar.bz2 spark-59c22fb444e7a03e2272be1d76e16960083d161d.zip | |
Print exit status in PipedRDD failure exception.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/PipedRDD.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/PipedRDD.scala b/core/src/main/scala/spark/PipedRDD.scala index 0b719a0d19..3103d7889b 100644 --- a/core/src/main/scala/spark/PipedRDD.scala +++ b/core/src/main/scala/spark/PipedRDD.scala @@ -64,8 +64,9 @@ class PipedRDD[T: ClassManifest]( if (lines.hasNext) { true } else { - if (proc.waitFor() != 0) { - throw new Exception("Subprocess exited with non-zero exit status") + val exitStatus = proc.waitFor() + if (exitStatus != 0) { + throw new Exception("Subprocess exited with status " + exitStatus) } false } |