diff --git a/pkg/cluster/pod.go b/pkg/cluster/pod.go index 885434c26..e974fba49 100644 --- a/pkg/cluster/pod.go +++ b/pkg/cluster/pod.go @@ -343,7 +343,8 @@ func (c *Cluster) recreatePods() error { role := PostgresRole(pod.Labels[c.OpConfig.PodRoleLabel]) // final check if spec of running pod differs from template - if pod.ObjectMeta.Labels["controller-revision-hash"] == c.Statefulset.Status.UpdateRevision { + if c.Statefulset.Status.CurrentRevision != c.Statefulset.Status.UpdateRevision && + pod.ObjectMeta.Labels["controller-revision-hash"] == c.Statefulset.Status.UpdateRevision { c.logger.Infof("%q pod %q already updated", role, podName) continue }