From 7a90fbcb0028391275260e0fbc088a703181d3c0 Mon Sep 17 00:00:00 2001 From: Felix Kunde Date: Fri, 27 Jan 2023 18:03:37 +0100 Subject: [PATCH] fix sync of stream slots (#2194) --- pkg/cluster/sync.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go index 477cbdc75..ecdda6998 100644 --- a/pkg/cluster/sync.go +++ b/pkg/cluster/sync.go @@ -647,7 +647,12 @@ func (c *Cluster) checkAndSetGlobalPostgreSQLConfiguration(pod *v1.Pod, effectiv } } slotsToSet[slotName] = desiredSlot - c.replicationSlots[slotName] = desiredSlot + // only add slots specified in manifest to c.replicationSlots + for manifestSlotName, _ := range c.Spec.Patroni.Slots { + if manifestSlotName == slotName { + c.replicationSlots[slotName] = desiredSlot + } + } } if len(slotsToSet) > 0 { configToSet["slots"] = slotsToSet