fix

2026-07-17 16:43:42 -07:00 · 2026-07-17 16:43:42 -07:00 · 0ccb75e514
parent fe1d52eacc
commit 0ccb75e514
1 changed files with 1 additions and 0 deletions
--- 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