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