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.
