From d5a8c998b031d27021d11d29cc7c20eeaeaa326b Mon Sep 17 00:00:00 2001
From: Alan Wang <alanwang599@gmail.com>
Date: Fri, 31 Jul 2026 12:54:25 -0700
Subject: [PATCH] fix

---
 .../apache/cassandra/service/accord/CoordinatedTransfer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
         {