Demonstrate errors reported in issue #27.

disq-bio · Oct 24, 2018 · 76605ca · 76605ca
1 parent 3b60e8b
commit 76605ca
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/test/java/org/disq_bio/disq/HtsjdkReadsRddTest.java b/src/test/java/org/disq_bio/disq/HtsjdkReadsRddTest.java
@@ -108,6 +108,9 @@ public void testReadAndWrite(
 
     HtsjdkReadsRdd htsjdkReadsRdd = htsjdkReadsRddStorage.read(inputPath);
 
+    // reduce to realize the RDD of reads
+    Assert.assertNotNull(htsjdkReadsRdd.getReads().first());
+
     // read the file using htsjdk to get expected number of reads, then count the number in the RDD
     int expectedCount = AnySamTestUtil.countReads(inputPath, refPath);
     Assert.assertEquals(expectedCount, htsjdkReadsRdd.getReads().count());

diff --git a/src/test/java/org/disq_bio/disq/HtsjdkVariantsRddTest.java b/src/test/java/org/disq_bio/disq/HtsjdkVariantsRddTest.java
@@ -71,6 +71,9 @@ public void testReadAndWrite(
 
     HtsjdkVariantsRdd htsjdkVariantsRdd = htsjdkVariantsRddStorage.read(inputPath);
 
+    // reduce to realize the RDD of variants
+    Assert.assertNotNull(htsjdkVariantsRdd.getVariants().first());
+
     // read the file using htsjdk to get expected number of reads, then count the number in the RDD
     int expectedCount = countVariants(inputPath);
     Assert.assertEquals(expectedCount, htsjdkVariantsRdd.getVariants().count());