From 5c86e7dc4be8f521f967e99ef7f159aa4aa806d5 Mon Sep 17 00:00:00 2001 From: Alan Wang Date: Fri, 17 Jul 2026 15:41:58 -0700 Subject: [PATCH] fix bug --- .../apache/cassandra/service/accord/CoordinatedTransfer.java | 3 ++- 1 file changed, 2 insertions(+), 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 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> entry : msgs.entrySet()) MessagingService.instance().sendWithCallback(entry.getValue(), entry.getKey(), notifyFailure); - notifyFailure.get(); + if (!msgs.isEmpty()) + notifyFailure.get(); } public static class NodeStreamingMetadata