diff --git a/test/distributed/org/apache/cassandra/distributed/impl/Instance.java b/test/distributed/org/apache/cassandra/distributed/impl/Instance.java index 39f5e980af..a8c948c25d 100644 --- a/test/distributed/org/apache/cassandra/distributed/impl/Instance.java +++ b/test/distributed/org/apache/cassandra/distributed/impl/Instance.java @@ -794,6 +794,7 @@ public class Instance extends IsolatedExecutor implements IInvokableInstance error = parallelRun(error, executor, () -> StorageService.instance.setRpcReady(false), + () -> StorageService.instance.setIsShutdownUnsafeForTests(true), CassandraDaemon.getInstanceForTesting()::destroyClientTransports); if (config.has(GOSSIP) || config.has(NETWORK))