diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala
index 207ad0cf13..9a18b76007 100644
--- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala
+++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorPruningSpec.scala
@@ -230,10 +230,22 @@ class ReplicatorPruningSpec extends MultiNodeSpec(ReplicatorPruningSpec) with ST
             retrieved.value should be(expectedValue)
         }
       }
+      def checkValuePropagated(expectedValue: Int): Unit =
+        awaitAssert {
+          replicator ! Get(KeyA, ReadLocal)
+          expectMsgPF() {
+            case g @ GetSuccess(KeyA, _) =>
+              g.get(KeyA).value.toInt should be(expectedValue)
+          }
+        }
 
       runOn(first) {
         updateAfterPruning(expectedValue = 10)
       }
+      runOn(second) {
+        checkValuePropagated(10)
+      }
+
       enterBarrier("update-first-after-pruning")
 
       runOn(second) {
@@ -248,6 +260,10 @@ class ReplicatorPruningSpec extends MultiNodeSpec(ReplicatorPruningSpec) with ST
       runOn(first) {
         updateAfterPruning(expectedValue = 12)
       }
+      runOn(second) {
+        checkValuePropagated(12)
+      }
+
       enterBarrier("update-first-after-dissemination")
 
       runOn(second) {