]
Adrian Nistor updated ISPN-5533:
--------------------------------
Fix Version/s: 8.2.0.Alpha1
(was: 8.1.0.Final)
M/R DeltaAwareList can add duplicate values because of topology
changes
-----------------------------------------------------------------------
Key: ISPN-5533
URL:
https://issues.jboss.org/browse/ISPN-5533
Project: Infinispan
Issue Type: Bug
Components: Core, Distributed Execution and Map/Reduce
Affects Versions: 7.2.2.Final, 8.0.0.Alpha1
Reporter: Dan Berindei
Fix For: 8.2.0.Alpha1
By default, the intermediate cache is non-transactional, so a topology change will cause
write commands to be retried. Because a {{PutKeyValueCommand(K, DeltaAwareList)}} command
is not idempotent, a retried command will append extra intermediate values to the list.
The M/R framework tries to guard against this by waiting for all the nodes to initialize
the intermediate cache before starting the reduce phase, but it cannot guard against nodes
joining or leaving during the reduce phase.