We need to ensure that we are not reading stale PV objects

So as we don't end up resizing same object more than once

Author: gnufied

pkg/controller/controller.go

@@ -341,6 +341,15 @@ func (ctrl *resizeController) pvNeedResize(pvc *v1.PersistentVolumeClaim, pv *v1
 		return false
 	}
 
+	// lets make sure that we are reading latest PV object so as any PV updates that might have happened
+	// is available and we do not inadvertently call resize again on same PV.
+	pv, err := ctrl.kubeClient.CoreV1().PersistentVolumes().Get(context.TODO(), pv.Name, metav1.GetOptions{})
+
+	if err != nil {
+		klog.Errorf("error fetching PersistentVolume %q: %v", pv.Name, err)
+		return false
+	}
+
 	pvSize := pv.Spec.Capacity[v1.ResourceStorage]
 	requestSize := pvc.Spec.Resources.Requests[v1.ResourceStorage]
 	if pvSize.Cmp(requestSize) >= 0 {