diff --git a/pkg/kubelet/volumemanager/cache/actual_state_of_world.go b/pkg/kubelet/volumemanager/cache/actual_state_of_world.go index 38b96457593..46cb842baa9 100644 --- a/pkg/kubelet/volumemanager/cache/actual_state_of_world.go +++ b/pkg/kubelet/volumemanager/cache/actual_state_of_world.go @@ -281,7 +281,8 @@ type attachedVolume struct { // for this volume and volume expansion on this node should not be retried volumeInUseErrorForExpansion bool - // persistentVolumeSize records size of the volume when pod was started. + // persistentVolumeSize records size of the volume when pod was started or + // size after successful completion of volume expansion operation. persistentVolumeSize *resource.Quantity } diff --git a/pkg/kubelet/volumemanager/cache/desired_state_of_world.go b/pkg/kubelet/volumemanager/cache/desired_state_of_world.go index 60f1a56852d..0a999833a5e 100644 --- a/pkg/kubelet/volumemanager/cache/desired_state_of_world.go +++ b/pkg/kubelet/volumemanager/cache/desired_state_of_world.go @@ -296,7 +296,8 @@ func (dsw *desiredStateOfWorld) AddPodToVolume( if volumeSpec.PersistentVolume != nil { pvCap := volumeSpec.PersistentVolume.Spec.Capacity.Storage() if pvCap != nil { - vmt.persistentVolumeSize = pvCap + pvCapCopy := pvCap.DeepCopy() + vmt.persistentVolumeSize = &pvCapCopy } }