From ea775a80e81390703ffef1ca9ad5ab2a510d30d7 Mon Sep 17 00:00:00 2001 From: Waldemar Quevedo Date: Mon, 18 Sep 2023 12:46:53 -0700 Subject: [PATCH] Skip TestJetStreamClusterRestartThenScaleStreamReplicas for now Signed-off-by: Waldemar Quevedo --- server/jetstream_cluster.go | 3 ++- server/jetstream_cluster_3_test.go | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) 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()