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