ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkulichenko <valentin.kuliche...@gmail.com>
Subject Re: Performance question
Date Mon, 28 Nov 2016 21:52:36 GMT
Alisher,

This line does not look correct to me:

int[] partitions =
this.ignite.affinity("test.cache").primaryPartitions(this.ignite.cluster().node());

cluster().node() returns a random node from the group, it should be
localNode() instead if I understand your approach correctly.

I would also try to manually start threads to make sure that parallelization
works properly. I'm not sure how it works if you use streams.

-Val



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Performance-question-tp9218p9239.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Mime
View raw message