From de5022ad7e8fc10d0be67d35810d93df376b346d Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Fri, 7 Jan 2022 07:44:30 -0800 Subject: [PATCH] Make cluster placement log more detailed Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index ef5f36ee..d3a4fb23 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -3394,7 +3394,12 @@ func (js *jetStream) processStreamAssignmentResults(sub *subscription, c *client // If we have additional clusters to try we can retry. if ci != nil && len(ci.Alternates) > 0 { if rg := js.createGroupForStream(ci, cfg); rg != nil { - s.Warnf("Retrying cluster placement for stream '%s > %s'", result.Account, result.Stream) + if org := sa.Group; org != nil && len(org.Peers) > 0 { + s.Warnf("Retrying cluster placement for stream '%s > %s' due to insufficient resources in cluster %q", + result.Account, result.Stream, s.clusterNameForNode(org.Peers[0])) + } else { + s.Warnf("Retrying cluster placement for stream '%s > %s' due to insufficient resources", result.Account, result.Stream) + } // Pick a new preferred leader. rg.setPreferred() // Get rid of previous attempt.