diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 2d6f30b5..205b5988 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -4264,7 +4264,8 @@ func (js *jetStream) processClusterCreateConsumer(ca *consumerAssignment, state } else { // Check for scale down to 1.. if rg.node != nil && len(rg.Peers) == 1 { - // Need to pop loopAndForward by closing qch and nil out both qch and pch. + // Need to pop loopAndForward by closing qch and nil out both qch and pch + // to avoid leaving a closed raft node forwarding proposals. o.clearLoopAndForward() o.clearNode() o.setLeader(true) diff --git a/server/jetstream_cluster_3_test.go b/server/jetstream_cluster_3_test.go index f619dc76..0a8a65bc 100644 --- a/server/jetstream_cluster_3_test.go +++ b/server/jetstream_cluster_3_test.go @@ -5685,6 +5685,8 @@ func TestJetStreamClusterDetectOrphanNRGs(t *testing.T) { } func TestJetStreamClusterRestartThenScaleStreamReplicas(t *testing.T) { + t.Skip("This test takes too long, need to make shorter") + c := createJetStreamClusterExplicit(t, "R3S", 3) defer c.shutdown()