diff options
author | Josh Rosen <rosenville@gmail.com> | 2012-07-26 11:31:47 -0700 |
---|---|---|
committer | Josh Rosen <rosenville@gmail.com> | 2012-07-26 11:32:59 -0700 |
commit | bf61c10072931d9b95f980015f2c4556f836e142 (patch) | |
tree | 271638d8a9f8fbf0f959d670c4fe69ee5a126c23 /core/src/test | |
parent | 4f4a34c02542bf3b1da71117a777e76441b89acf (diff) | |
download | spark-bf61c10072931d9b95f980015f2c4556f836e142.tar.gz spark-bf61c10072931d9b95f980015f2c4556f836e142.tar.bz2 spark-bf61c10072931d9b95f980015f2c4556f836e142.zip |
Detect non-zero exit status from PipedRDD process.
Diffstat (limited to 'core/src/test')
-rw-r--r-- | core/src/test/scala/spark/PipedRDDSuite.scala | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/core/src/test/scala/spark/PipedRDDSuite.scala b/core/src/test/scala/spark/PipedRDDSuite.scala index db1b9835a0..d010a9be7a 100644 --- a/core/src/test/scala/spark/PipedRDDSuite.scala +++ b/core/src/test/scala/spark/PipedRDDSuite.scala @@ -39,6 +39,15 @@ class PipedRDDSuite extends FunSuite with BeforeAndAfter { assert(c(1) === "LALALA") } + test("pipe with non-zero exit status") { + sc = new SparkContext("local", "test") + val nums = sc.makeRDD(Array(1, 2, 3, 4), 2) + val piped = nums.pipe("cat nonexistent_file") + intercept[SparkException] { + piped.collect() + } + } + } |