diff --git a/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java b/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java
index dc7b8a592b..7a41adfaa7 100644
--- a/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java
+++ b/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java
@@ -119,10 +119,10 @@ public class CoordinatedTransfer
     {
         logger.debug("{} Executing Accord bulk transfer {}", logPrefix(), this);
         LocalTransfers.instance().save(this);
+        stream();
         PendingLocalTransfer pendingLocalTransfer = LocalTransfers.instance().local.get(streamResult.planId);
         CountDownLatch latch = new CountDownLatch(1);
         pendingLocalTransfer.registerLatch(latch);
-        stream();
 
         try
         {