diff --git a/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java b/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java
index 60d23aa18d..b52369330f 100644
--- a/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java
+++ b/src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java
@@ -369,7 +369,8 @@ public class CoordinatedTransfer
         for (Map.Entry<InetAddressAndPort,Message<TransferFailed>> entry : msgs.entrySet())
             MessagingService.instance().sendWithCallback(entry.getValue(), entry.getKey(), notifyFailure);
 
-        notifyFailure.get();
+        if (!msgs.isEmpty())
+            notifyFailure.get();
     }
 
     public static class NodeStreamingMetadata