diff --git a/controllers/upgrade.go b/controllers/upgrade.go index 34d3bbf00..dcebe50ca 100644 --- a/controllers/upgrade.go +++ b/controllers/upgrade.go @@ -409,6 +409,13 @@ func (r *PravegaClusterReconciler) syncSegmentStoreVersion(p *pravegav1beta1.Pra } if pod == nil { + pods, err := r.getStsPodsWithVersion(sts, p.Status.TargetVersion) + if err != nil { + return false, err + } + if *sts.Spec.Replicas == (int32)(len(pods)) { + return false, nil + } return false, fmt.Errorf("could not obtain outdated pod") }