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.CR1 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.