#IGNITE-SQL Fixed IgniteCacheSqlQueryMultiThreadedSelfTest.testQuery

apache · Feb 13, 2015 · 602eef7 · 602eef7
1 parent d9a3b3b
commit 602eef7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...org/apache/ignite/internal/processors/cache/IgniteCacheSqlQueryMultiThreadedSelfTest.java b/...org/apache/ignite/internal/processors/cache/IgniteCacheSqlQueryMultiThreadedSelfTest.java
@@ -94,12 +94,12 @@ public void testQuery() throws Exception {
         GridTestUtils.runMultiThreaded(new Callable<Void>() {
             @Override public Void call() throws Exception {
                 for (int i = 0; i < 100; i++) {
-                    Iterator<Cache.Entry<Integer, Person>> iter =
+                    QueryCursor<Cache.Entry<Integer, Person>> qry =
-                        cache.query(new SqlQuery("age >= 0").setType("Person")).iterator();
+                        cache.query(new SqlQuery("age >= 0").setType("Person"));
 
                     int cnt = 0;
 
-                    while (iter.next() != null)
+                    for (Cache.Entry<Integer, Person> e : qry)
                         cnt++;
 
                     assertEquals(2000, cnt);