diff --git a/pkg/kubelet/pod/mirror_client.go b/pkg/kubelet/pod/mirror_client.go index b5f7490e59a..22ea62b1a31 100644 --- a/pkg/kubelet/pod/mirror_client.go +++ b/pkg/kubelet/pod/mirror_client.go @@ -153,12 +153,6 @@ func (mc *basicMirrorClient) getNodeUID() (types.UID, error) { return node.UID, nil } -// IsStaticPod returns true if the passed Pod is static. -func IsStaticPod(pod *v1.Pod) bool { - source, err := kubetypes.GetPodSource(pod) - return err == nil && source != kubetypes.ApiserverSource -} - func getHashFromMirrorPod(pod *v1.Pod) (string, bool) { hash, ok := pod.Annotations[kubetypes.ConfigMirrorAnnotationKey] return hash, ok diff --git a/pkg/kubelet/types/pod_update.go b/pkg/kubelet/types/pod_update.go index 9420eef1eb3..d51d3fc963a 100644 --- a/pkg/kubelet/types/pod_update.go +++ b/pkg/kubelet/types/pod_update.go @@ -142,6 +142,9 @@ func (sp SyncPodType) String() string { // IsMirrorPod returns true if the passed Pod is a Mirror Pod. func IsMirrorPod(pod *v1.Pod) bool { + if pod.Annotations == nil { + return false + } _, ok := pod.Annotations[ConfigMirrorAnnotationKey] return ok }