New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Added test to try and repro #1282. #1292

Closed
wants to merge 1 commit into
base: master
from
Jump to file or symbol
Failed to load files and symbols.
+14 −0
Diff settings

Always

Just for now

Added test to try and repro #1282.

  • Loading branch information...
fnothaft committed Nov 26, 2016
commit 1dc5e876563da35540600632efb7ad0a3f49cf02
@@ -20,6 +20,7 @@ package org.bdgenomics.adam.rdd.read
import java.io.File
import java.nio.file.Files
import htsjdk.samtools.ValidationStringency
import org.apache.spark.SparkException
import org.bdgenomics.adam.models.{
RecordGroupDictionary,
ReferenceRegion,
@@ -708,4 +709,17 @@ class AlignmentRecordRDDSuite extends ADAMFunSuite {
val tempBam = sc.loadBam(tempPath)
assert(tempBam.rdd.count === ardd.rdd.count)
}
sparkTest("don't hang on pipe exception") {
val readsPath = testFile("small.1.sam")
val ardd = sc.loadBam(readsPath)
implicit val tFormatter = SAMInFormatter
implicit val uFormatter = new VCFOutFormatter
intercept[SparkException] {
val pipedRdd: VariantContextRDD = ardd.pipe("tee /dev/null")
val newRecords = pipedRdd.rdd.count
}
}
}
ProTip! Use n and p to navigate between commits in a pull request.