Skip to content
Snippets Groups Projects
Commit d362d0f4 authored by Shivaram Venkataraman's avatar Shivaram Venkataraman
Browse files

Ignore stderr when calling cat on a non-existing file

parent 3350ad0d
No related branches found
No related tags found
No related merge requests found
...@@ -67,7 +67,7 @@ class PipedRDDSuite extends FunSuite with SharedSparkContext { ...@@ -67,7 +67,7 @@ class PipedRDDSuite extends FunSuite with SharedSparkContext {
test("pipe with non-zero exit status") { test("pipe with non-zero exit status") {
val nums = sc.makeRDD(Array(1, 2, 3, 4), 2) 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] { intercept[SparkException] {
piped.collect() piped.collect()
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment