diff --git a/server/norace_test.go b/server/norace_test.go index 1d8268e2..8955d2fa 100644 --- a/server/norace_test.go +++ b/server/norace_test.go @@ -1975,6 +1975,7 @@ func TestNoRaceJetStreamClusterMirrorExpirationAndMissingSequences(t *testing.T) // Now shutdown the server with the mirror. ms := c.streamLeader("$G", "M") ms.Shutdown() + c.waitOnLeader() // Send more messages but let them expire. sendBatch(10)