putAll stoping at 600 entries.

[javadevmtl]

Using 1.3.0

I have my cache configured as follows...

private static IgniteCache<String, HashSet&lt;String>> cache = null;

IgniteConfiguration igniteCfg = new IgniteConfiguration();
igniteCfg.setMarshaller(new OptimizedMarshaller(true));
                                                        
CacheConfiguration<String, HashSet&lt;String>> myCfg = new
CacheConfiguration<>("cache");
myCfg.setCacheMode(CacheMode.PARTITIONED);
myCfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
myCfg.setMemoryMode(CacheMemoryMode.OFFHEAP_TIERED);
myCfg.setOffHeapMaxMemory(64 * 1024L * 1024L * 1024L);
myCfg.setBackups(0);
ignite = Ignition.start(igniteCfg);                                             
cache = ignite.getOrCreateCache(myCfg).withAsync();

// Then in my "web" handler for each request

final JsonArray jsonKeys = request.getJsonArray("keys");
Map<String, HashSet&lt;String>> keysValues = new HashMap<>();

                                
for(int i = 0; i < jsonKeys.size(); i++) {
        String keyPrefix = jsonKeys.getJsonObject(i).getString("keyPrefix");
        String key = keyPrefix + jsonKeys.getJsonObject(i).getString("key");

        HashSet<String> value = new HashSet<String>();
        value.add(jsonKeys.getJsonObject(i).getString("value"));

        keysValues.put(key, value);
}
                                
cache.putAll(keysValues);
IgniteFuture<Void> putFut = cache.future();
                                
putFut.listen(f -> {
        myWebHandler.reply(new JsonObject().put("result", "written"));
});


For what ever reason it seems to hang after 600 entries... Currently I'm
putting in 18 keys per request.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/putAll-stoping-at-600-entries-tp817.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.