From 0ccb75e514c571f3b4b69f8468eee79fffe6399f Mon Sep 17 00:00:00 2001 From: Alan Wang Date: Fri, 17 Jul 2026 16:43:42 -0700 Subject: [PATCH] fix --- src/java/org/apache/cassandra/service/accord/LocalTransfers.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/java/org/apache/cassandra/service/accord/LocalTransfers.java b/src/java/org/apache/cassandra/service/accord/LocalTransfers.java index a899e6a166..18f7601897 100644 --- a/src/java/org/apache/cassandra/service/accord/LocalTransfers.java +++ b/src/java/org/apache/cassandra/service/accord/LocalTransfers.java @@ -160,6 +160,7 @@ public class LocalTransfers logger.debug("Deleting pending transfer directory: {}", pendingDir); pendingDir.deleteRecursive(); } + local.remove(transfer.planId); } } finally