fix sync of stream slots (#2194)

FxKu · web-flow · commit 7a90fbcb0028 · 2023-01-27T18:03:37.000+01:00
diff --git 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

Original file line number	Diff line number	Diff line change
`@@ -647,7 +647,12 @@ func (c Cluster) checkAndSetGlobalPostgreSQLConfiguration(pod v1.Pod, effectiv`
`647`	`647`	`}`
`648`	`648`	`}`
`649`	`649`	`slotsToSet[slotName] = desiredSlot`
`650`		`- c.replicationSlots[slotName] = desiredSlot`
	`650`	`+ // only add slots specified in manifest to c.replicationSlots`
	`651`	`+ for manifestSlotName, _ := range c.Spec.Patroni.Slots {`
	`652`	`+ if manifestSlotName == slotName {`
	`653`	`+ c.replicationSlots[slotName] = desiredSlot`
	`654`	`+ }`
	`655`	`+ }`
`651`	`656`	`}`
`652`	`657`	`if len(slotsToSet) > 0 {`
`653`	`658`	`configToSet["slots"] = slotsToSet`