#IGNITE-53: wip

apache · Jan 20, 2015 · 83a571b · 83a571b
1 parent c500eda
commit 83a571b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
@@ -982,7 +982,13 @@ public void removeAll(Collection<? extends K> keys) {
         try {
             ctx.itHolder().checkWeakQueue();
 
-            GridCacheQueryFuture<Map.Entry<K, V>> fut =  delegate.queries().createScanQuery(null).execute();
+            GridCacheQuery<Map.Entry<K, V>> query =  delegate.queries().createScanQuery(null);
+
+            query.includeBackups(false);
+            query.enableDedup(true);
+            query.keepAll(false);
+
+            GridCacheQueryFuture<Map.Entry<K, V>> fut = query.execute();
 
             return ctx.itHolder().iterator(fut, new CacheIteratorConverter<Entry<K, V>, Map.Entry<K, V>>() {
                 @Override protected Entry<K, V> convert(Map.Entry<K, V> e) {

diff --git a/...test/java/org/gridgain/grid/kernal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/...test/java/org/gridgain/grid/kernal/processors/cache/GridCacheAbstractFullApiSelfTest.java
@@ -5087,7 +5087,7 @@ public void testIgniteCacheIterator() throws Exception {
 
         assertFalse(cache.iterator().hasNext());
 
-        final int SIZE = 1000;
+        final int SIZE = 20000;
 
         Map<String, Integer> entries = new HashMap<>();