Issue 220: Fix for intermittent bookkeeper cluster upgrade failure (#237

) Signed-off-by: anisha.kj <[email protected]>
pravega · Oct 11, 2023 · b80fb7c · b80fb7c
1 parent 5257dd4
commit b80fb7c
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/controllers/upgrade.go b/controllers/upgrade.go
@@ -282,6 +282,14 @@ func (r *BookkeeperClusterReconciler) syncBookkeeperVersion(bk *bookkeeperv1alph
 		}
 
 		if pod == nil {
+			pods, err := r.getStsPodsWithVersion(sts, bk.Status.TargetVersion)
+			if err != nil {
+				return false, err
+			}
+			if *sts.Spec.Replicas == (int32)(len(pods)) {
+				log.Infof("All bookkeeper pods are updated")
+				return false, nil
+			}
 			return false, fmt.Errorf("could not obtain outdated pod")
 		}