diff options
| author | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-07-07 03:33:32 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-07-07 04:09:46 -0700 |
| commit | d362d0f4117268bdef265041ff291700ddd49b43 (patch) | |
| tree | 764e2544fefaeab132a0b141e2d004d45d1439d2 /core | |
| parent | 3350ad0d7fc3ecece78f87d7aa6a727e48b21c8c (diff) | |
| download | spark-d362d0f4117268bdef265041ff291700ddd49b43.tar.gz spark-d362d0f4117268bdef265041ff291700ddd49b43.tar.bz2 spark-d362d0f4117268bdef265041ff291700ddd49b43.zip | |
Ignore stderr when calling cat on a non-existing file
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/test/scala/spark/PipedRDDSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/test/scala/spark/PipedRDDSuite.scala b/core/src/test/scala/spark/PipedRDDSuite.scala index 1c9ca50811..d263bb00e9 100644 --- a/core/src/test/scala/spark/PipedRDDSuite.scala +++ b/core/src/test/scala/spark/PipedRDDSuite.scala @@ -67,7 +67,7 @@ class PipedRDDSuite extends FunSuite with SharedSparkContext { test("pipe with non-zero exit status") { val nums = sc.makeRDD(Array(1, 2, 3, 4), 2) - val piped = nums.pipe("cat nonexistent_file") + val piped = nums.pipe(Seq("cat nonexistent_file", "2>", "/dev/null")) intercept[SparkException] { piped.collect() } |