kubernetes
/
autoscaler
mirror of https://github.com/kubernetes/autoscaler.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Address review comments

This commit is contained in:
Plamen Kokanov 2025-04-28 10:11:13 +03:00
parent 71ddfb7be0
commit 260c306ab4
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
vertical-pod-autoscaler/pkg/recommender/input/cluster_feeder.go
View File

@ -499,6 +499,7 @@ func (feeder *clusterStateFeeder) LoadRealTimeMetrics(ctx context.Context) {
sampleCount := 0
droppedSampleCount := 0
for _, containerMetrics := range containersMetrics {
// Container metrics are fetched for all pods, however, not all pod states are tracked in memory saver mode.
if pod, exists := feeder.clusterState.Pods()[containerMetrics.ID.PodID]; exists && pod != nil {
if slices.Contains(pod.InitContainers, containerMetrics.ID.ContainerName) {
klog.V(3).InfoS("Skipping metric samples for init container", "pod", klog.KRef(containerMetrics.ID.PodID.Namespace, containerMetrics.ID.PodID.PodName), "container", containerMetrics.ID.ContainerName)
@ -508,7 +509,7 @@ func (feeder *clusterStateFeeder) LoadRealTimeMetrics(ctx context.Context) {
}
for _, sample := range newContainerUsageSamplesWithKey(containerMetrics) {
if err := feeder.clusterState.AddSample(sample); err != nil {
// Not all pod states are tracked in memory saver mode
// Not all pod states are tracked in memory saver mode.
if _, isKeyError := err.(model.KeyError); isKeyError && feeder.memorySaveMode {
continue
}