nit

hammerlab · Oct 29, 2017 · ca3cf2c · ca3cf2c
1 parent 5090a4f
commit ca3cf2c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/org/bdgenomics/adam/rdd/read/AlignmentRecordRDD.scala b/src/main/scala/org/bdgenomics/adam/rdd/read/AlignmentRecordRDD.scala
@@ -825,7 +825,7 @@ case class AlignmentRecordRDD(
       case SILENT ⇒
     }
 
-    val pairedRecords: RDD[AlignmentRecord] = readsByID.filter(_._2.size == 2).map(_._2).flatMap(x => x)
+    val pairedRecords: RDD[AlignmentRecord] = readsByID.filter(_._2.size == 2).values.flatMap(x => x)
     maybePersist(pairedRecords)
     val numPairedRecords = pairedRecords.count()