Make sure to delete the stream assignment node here

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-05-17 16:19:39 -07:00
parent f3553791b1
commit a8d7d3886e

View File

@@ -528,6 +528,7 @@ func (js *jetStream) isStreamHealthy(acc *Account, sa *streamAssignment) bool {
}
} else if node != nil && node != mset.raftNode() {
s.Warnf("Detected stream cluster node skew '%s > %s'", acc.GetName(), streamName)
node.Delete()
mset.resetClusteredState(nil)
}