Fix for a bug where the incoming messages (at reducers) were duplicated n*n times if we start n predecessors (mappers).