Skip TestJetStreamClusterRestartThenScaleStreamReplicas for now

Signed-off-by: Waldemar Quevedo <wally@synadia.com>
This commit is contained in:
Waldemar Quevedo
2023-09-18 12:46:53 -07:00
parent 850c89e175
commit ea775a80e8
2 changed files with 4 additions and 1 deletions

View File

@@ -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)

View File

@@ -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()