Populate status memory requests from actuated resources

vinaykul · vinaykul · commit ec1b493a088e · 2025-03-20T01:46:28.000Z
diff --git a/pkg/kubelet/kubelet_pods.go b/pkg/kubelet/kubelet_pods.go
@@ -2105,6 +2105,13 @@ func (kl *Kubelet) convertToAPIContainerStatuses(pod *v1.Pod, podStatus *kubecon
 			} else {
 				preserveOldResourcesValue(v1.ResourceCPU, oldStatus.Resources.Requests, resources.Requests)
 			}
+			// TODO(tallclair,vinaykul,InPlacePodVerticalScaling): Investigate defaulting to actuated resources instead of allocated resources above
+			if _, exists := resources.Requests[v1.ResourceMemory]; exists {
+				// Get memory requests from actuated resources
+				if actuatedResources, found := kl.allocationManager.GetActuatedResources(pod.UID, allocatedContainer.Name); found {
+					resources.Requests[v1.ResourceMemory] = actuatedResources.Requests.Memory().DeepCopy()
+				}
+			}
 		}
 
 		return resources

Original file line number	Diff line number	Diff line change
`@@ -2105,6 +2105,13 @@ func (kl Kubelet) convertToAPIContainerStatuses(pod v1.Pod, podStatus *kubecon`
`2105`	`2105`	`} else {`
`2106`	`2106`	`preserveOldResourcesValue(v1.ResourceCPU, oldStatus.Resources.Requests, resources.Requests)`
`2107`	`2107`	`}`
	`2108`	`+ // TODO(tallclair,vinaykul,InPlacePodVerticalScaling): Investigate defaulting to actuated resources instead of allocated resources above`
	`2109`	`+ if _, exists := resources.Requests[v1.ResourceMemory]; exists {`
	`2110`	`+ // Get memory requests from actuated resources`
	`2111`	`+ if actuatedResources, found := kl.allocationManager.GetActuatedResources(pod.UID, allocatedContainer.Name); found {`
	`2112`	`+ resources.Requests[v1.ResourceMemory] = actuatedResources.Requests.Memory().DeepCopy()`
	`2113`	`+ }`
	`2114`	`+ }`
`2108`	`2115`	`}`
`2109`	`2116`
`2110`	`2117`	`return resources`