diff --git a/server/jetstream_cluster_test.go b/server/jetstream_cluster_test.go index 9e26ed00..4ddcd528 100644 --- a/server/jetstream_cluster_test.go +++ b/server/jetstream_cluster_test.go @@ -8028,6 +8028,11 @@ func TestJetStreamRaceOnRAFTCreate(t *testing.T) { t.Fatalf("Error creating stream: %v", err) } + js, err = nc.JetStream(nats.MaxWait(time.Second)) + if err != nil { + t.Fatal(err) + } + size := 10 wg := sync.WaitGroup{} wg.Add(size)