From a5ee7141d9d5de150feb34bc99904d900960549f Mon Sep 17 00:00:00 2001 From: Holden Karau Date: Thu, 27 Mar 2014 13:47:34 -0700 Subject: [PATCH] oops, was checking wrong iterator --- .../src/test/java/org/apache/spark/streaming/JavaAPISuite.java | 2 +- 1 file changed, 1 insertion(+), 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 index 2a1becc74cbc7..c0e125e3af88b 100644 --- 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()); } }