Skip to content

Commit 3678433

Browse files
committed
Sync the status of static Pods
1 parent de63e57 commit 3678433

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

pkg/kubelet/kubelet_getters.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ import (
3333
"k8s.io/kubernetes/pkg/kubelet/cm"
3434
"k8s.io/kubernetes/pkg/kubelet/config"
3535
kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
36+
kubelettypes "k8s.io/kubernetes/pkg/kubelet/types"
3637
utilnode "k8s.io/kubernetes/pkg/util/node"
3738
)
3839

@@ -167,8 +168,11 @@ func (kl *Kubelet) GetPods() []*v1.Pod {
167168
// a kubelet running without apiserver requires an additional
168169
// update of the static pod status. See #57106
169170
for _, p := range pods {
170-
if status, ok := kl.statusManager.GetPodStatus(p.UID); ok {
171-
p.Status = status
171+
if kubelettypes.IsStaticPod(p) {
172+
if status, ok := kl.statusManager.GetPodStatus(p.UID); ok {
173+
klog.V(2).Infof("status for pod %v updated to %v", p.Name, status)
174+
p.Status = status
175+
}
172176
}
173177
}
174178
return pods

0 commit comments

Comments
 (0)