diff --git a/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java b/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java
index 90675d930..3645f5bee 100644
--- a/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java
+++ b/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java
@@ -126,6 +126,7 @@ public abstract class ReplicatedMapSegmentIteration<K, V, R> extends MapSegmentI
     public void doRemoveCompletely() {
         boolean wasDeleted = e.entryDeleted();
         super.doRemove();
+        ru.dropChange();
         if (wasDeleted)
             s.tierDeleted(s.tierDeleted() - 1);
     }
diff --git a/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java b/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java
index 8f3dd3f49..e54669038 100644
--- a/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java
+++ b/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java
@@ -88,6 +88,7 @@ public abstract class ReplicatedMapQuery<K, V, R> extends MapQuery<K, V, R>
     public void doRemoveCompletely() {
         boolean wasDeleted = e.entryDeleted();
         super.doRemove();
+        ru.dropChange();
         if (wasDeleted)
             s.tierDeleted(s.tierDeleted() - 1L);
     }