From a8d7d3886e81ac9aae160f279e7d5c3a1dfad669 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Wed, 17 May 2023 16:19:39 -0700 Subject: [PATCH] Make sure to delete the stream assignment node here Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 1 + 1 file changed, 1 insertion(+) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 5972ba5bae8..0c6e0fd7eec 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -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) }