cancel streams

palantir · Dec 13, 2024 · 35cf3ec · 35cf3ec
1 parent dd385f9
commit 35cf3ec
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
@@ -1616,6 +1616,7 @@ private boolean bootstrap(final Collection<Token> tokens)
                     logger.info("Stopped waiting for bootstrap streaming to complete because detected a bootstrap error.", SafeArg.of("nonTransientErrors", getNonTransientErrors()));
                     break;
                 }
+                bootstrapStream.cancel(true);
                 Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
             }
             isBootstrapMode = false;