natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix bug

This commit is contained in:
Alan Wang 2026-07-17 15:41:58 -07:00
parent 27e44640a1
commit 5c86e7dc4b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/java/org/apache/cassandra/service/accord/CoordinatedTransfer.java
View File

@ -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