cleanup local map

This commit is contained in:
Alan Wang 2026-07-17 16:45:40 -07:00
parent adbd3139d0
commit e4f7ed7730
2 changed files with 2 additions and 1 deletions

View File

@ -346,6 +346,7 @@ public class TransferTrackingService
pendingDir.deleteRecursive();
}
}
local.remove(transfer.planId);
}
finally
{

View File

@ -333,7 +333,7 @@ public class TrackedImportFailureTest extends TrackedTransferTestBase
Uninterruptibles.sleepUninterruptibly(5, TimeUnit.SECONDS);
// We exclude the missed instance because the SSTables streamed to the pending directory
// are not linked to LocalTransfers and hence cleanup does not know which SSTables to clean up
// are not linked to TransferTrackingService and hence cleanup does not know which SSTables to clean up
assertPendingDirs(cluster.stream().filter(instance -> instance != missed).collect(Collectors.toList()), (File pendingUuidDir) -> {
Assertions.assertThat(pendingUuidDir.listUnchecked(File::isFile)).isEmpty();
});