Re: Effective Data through DataStream

[mimmo_c]

Hi, 

Thanks for response.
The versione of Ignite is 2.0.
Configuration of Server:

    <bean id="cacheconf"
class="org.apache.ignite.configuration.CacheConfiguration">
        <property name="name" value="default"/>
        <property name="atomicityMode" value="ATOMIC"/>
        <property name="backups" value="0"/>
        <property name="cacheMode" value="PARTITIONED"/>
    </bean>

for all 4 Server.

Code:

try(IgniteDataStreamer<Long, Integer> stmr =
ignite.dataStreamer("default")){
               stmr.allowOverwrite(true); --->//Increase time execution
               stmr.perNodeBufferSize(8192);
               stmr.perNodeParallelOperations(16);
               in = System.currentTimeMillis();
               stmr.receiver(new UpdateWord2()); --->//Function for update
value in cache
               
                System.out.println("Size Map "+y+" : "+maps.size());
                for(Entry<Long, Integer> entry : maps.entrySet()){
                        
stmr.addData(entry.getKey().longValue(),entry.getValue());
                }
                stmr.flush();
}

I need to caching large amount of data in a Server of 20 Node, with a total
memory of 500Gb. Monitoring the ram memory of Node Server during passing
data through the network 2 Node stuck with java.lang.OutOfMemoryError
consuming all memory while memory consuming of other node is normal.

Thank you for support.
Mimmo




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/