diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java index ba431437c1..19519d0624 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java @@ -339,11 +339,8 @@ public class EventuallyConsistentMapImpl checkNotNull(value, ERROR_NULL_VALUE); MapValue newValue = new MapValue<>(value, timestampProvider.apply(key, value)); - // Before mutating local map, ensure the update can be serialized without errors. - // This prevents replica divergence due to serialization failures. - UpdateEntry update = serializer.copy(new UpdateEntry(key, newValue)); if (putInternal(key, newValue)) { - notifyPeers(update, peerUpdateFunction.apply(key, value)); + notifyPeers(new UpdateEntry(key, newValue), peerUpdateFunction.apply(key, value)); notifyListeners(new EventuallyConsistentMapEvent<>(mapName, PUT, key, value)); } }