oops, was checking wrong iterator

witgo · Apr 8, 2014 · a5ee714 · a5ee714
1 parent e687f21
commit a5ee714
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
@@ -1039,7 +1039,7 @@ public void testPairGroupByKey() {
         Assert.assertEquals(expectedElement._1(), resultElement._1());
         equalIterator(expectedElement._2().iterator(), resultElement._2());
       }
-      Assert.assertEquals(resultElements.hasNext(), expectedItr.hasNext());
+      Assert.assertEquals(resultElements.hasNext(), expectedElements.hasNext());
     }
   }