You're iterating through some collection of key-value pairs and then use
value from that pair within the entry processor, which is incorrect. You
should always use the one acquired via entry.getValue(); there.

I would actually recommend you to create a separate class instead of using
lambda for entry processor implementation. That would help you to avoid this
kind of errors, as well as various serialization issues (entry processors
are sent across the network which can cause unexpected behavior in case
lambdas or anonymous classes are used).

-Val



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

Reply via email to