From ca670680f0f25b7071ef39b2e72f1205213484c8 Mon Sep 17 00:00:00 2001
From: Fedotov <vanen31@gmail.com>
Date: Fri, 16 Mar 2018 14:45:55 +0300
Subject: [PATCH] remove U.capacity()

---
 .../java/org/apache/ignite/internal/binary/BinaryUtils.java   | 4 ++--
 .../internal/processors/datastreamer/DataStreamerImpl.java    | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java
index 2ef57e19199bc..1f167f5f08080 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java
@@ -667,7 +667,7 @@ else if (cls == LinkedHashMap.class)
         else if (!wrapTrees() && cls == TreeMap.class)
             return new TreeMap<>(((TreeMap<Object, Object>)map).comparator());
         else if (cls == ConcurrentHashMap.class)
-            return new ConcurrentHashMap<>(U.capacity(((Map)map).size()));
+            return new ConcurrentHashMap<>(((Map)map).size());
 
         return null;
     }
@@ -685,7 +685,7 @@ public static <K, V> Map<K, V> newMap(Map<K, V> map) {
         else if (map instanceof TreeMap)
             return new TreeMap<>(((TreeMap<Object, Object>)map).comparator());
         else if (map instanceof ConcurrentHashMap)
-            return new ConcurrentHashMap<>(U.capacity(map.size()));
+            return new ConcurrentHashMap<>(map.size());
 
         return U.newHashMap(map.size());
     }
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
index 1df8d579f8a3d..4a893f4096877 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
@@ -571,7 +571,7 @@ else if (autoFlushFreq == 0)
             activeFuts.add(resFut);
 
             Collection<KeyCacheObjectWrapper> keys =
-                new GridConcurrentHashSet<>(entries.size(), U.capacity(entries.size()), 1);
+                new GridConcurrentHashSet<>(entries.size());
 
             Collection<DataStreamerEntry> entries0 = new ArrayList<>(entries.size());
 
@@ -630,7 +630,7 @@ public IgniteFuture<?> addDataInternal(Collection<? extends DataStreamerEntry> e
             Collection<KeyCacheObjectWrapper> keys = null;
 
             if (entries.size() > 1) {
-                keys = new GridConcurrentHashSet<>(entries.size(), U.capacity(entries.size()), 1);
+                keys = new GridConcurrentHashSet<>(entries.size());
 
                 for (DataStreamerEntry entry : entries)
                     keys.add(new KeyCacheObjectWrapper(entry.getKey()));