diff --git a/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedImportFailureTest.java b/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedImportFailureTest.java index c669a18ea1..a8755cf0af 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedImportFailureTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedImportFailureTest.java @@ -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 cleanup + // are not linked to LocalTransfers 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(); });