Issue 643: Fixing intermittent upgrade failure (#672)

* Issue 643: Fixing intermittent upgrade failure Signed-off-by: anisha.kj <[email protected]> * Adding logs Signed-off-by: anisha.kj <[email protected]> * Fixed the typo Signed-off-by: anisha.kj <[email protected]> --------- Signed-off-by: anisha.kj <[email protected]>
pravega · Oct 11, 2023 · d970e05 · d970e05
1 parent 2d60c29
commit d970e05
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/controllers/upgrade.go b/controllers/upgrade.go
@@ -409,6 +409,14 @@ 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)) {
+				log.Infof("All segmentstore pods are updated")
+				return false, nil
+			}
 			return false, fmt.Errorf("could not obtain outdated pod")
 		}