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/