diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index 8d917fd7ce3..0d37ff804d7 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -2851,7 +2851,7 @@ func validateBandwidthIsReasonable(rsrc *resource.Quantity) error { } func extractBandwidthResources(pod *api.Pod) (ingress, egress *resource.Quantity, err error) { - str, found := pod.Annotations["kubernetes.io/ingress-bandwidth"] + str, found := pod.Annotations["net.alpha.kubernetes.io/ingress-bandwidth"] if found { if ingress, err = resource.ParseQuantity(str); err != nil { return nil, nil, err @@ -2860,7 +2860,7 @@ func extractBandwidthResources(pod *api.Pod) (ingress, egress *resource.Quantity return nil, nil, err } } - str, found = pod.Annotations["kubernetes.io/egress-bandwidth"] + str, found = pod.Annotations["net.alpha.kubernetes.io/egress-bandwidth"] if found { if egress, err = resource.ParseQuantity(str); err != nil { return nil, nil, err diff --git a/pkg/kubelet/kubelet_test.go b/pkg/kubelet/kubelet_test.go index d3d7940c7f3..2d2ab648066 100644 --- a/pkg/kubelet/kubelet_test.go +++ b/pkg/kubelet/kubelet_test.go @@ -3442,7 +3442,7 @@ func TestCleanupBandwidthLimits(t *testing.T) { ObjectMeta: api.ObjectMeta{ Name: "foo", Annotations: map[string]string{ - "kubernetes.io/ingress-bandwidth": "10M", + "net.alpha.kubernetes.io/ingress-bandwidth": "10M", }, }, }, @@ -3467,7 +3467,7 @@ func TestCleanupBandwidthLimits(t *testing.T) { ObjectMeta: api.ObjectMeta{ Name: "foo", Annotations: map[string]string{ - "kubernetes.io/ingress-bandwidth": "10M", + "net.alpha.kubernetes.io/ingress-bandwidth": "10M", }, }, }, @@ -3493,7 +3493,7 @@ func TestCleanupBandwidthLimits(t *testing.T) { ObjectMeta: api.ObjectMeta{ Name: "foo", Annotations: map[string]string{ - "kubernetes.io/ingress-bandwidth": "10M", + "net.alpha.kubernetes.io/ingress-bandwidth": "10M", }, }, }, @@ -3518,7 +3518,7 @@ func TestCleanupBandwidthLimits(t *testing.T) { ObjectMeta: api.ObjectMeta{ Name: "foo", Annotations: map[string]string{ - "kubernetes.io/ingress-bandwidth": "10M", + "net.alpha.kubernetes.io/ingress-bandwidth": "10M", }, }, }, @@ -3606,7 +3606,7 @@ func TestExtractBandwidthResources(t *testing.T) { pod: &api.Pod{ ObjectMeta: api.ObjectMeta{ Annotations: map[string]string{ - "kubernetes.io/ingress-bandwidth": "10M", + "net.alpha.kubernetes.io/ingress-bandwidth": "10M", }, }, }, @@ -3616,7 +3616,7 @@ func TestExtractBandwidthResources(t *testing.T) { pod: &api.Pod{ ObjectMeta: api.ObjectMeta{ Annotations: map[string]string{ - "kubernetes.io/egress-bandwidth": "10M", + "net.alpha.kubernetes.io/egress-bandwidth": "10M", }, }, }, @@ -3626,8 +3626,8 @@ func TestExtractBandwidthResources(t *testing.T) { pod: &api.Pod{ ObjectMeta: api.ObjectMeta{ Annotations: map[string]string{ - "kubernetes.io/ingress-bandwidth": "4M", - "kubernetes.io/egress-bandwidth": "20M", + "net.alpha.kubernetes.io/ingress-bandwidth": "4M", + "net.alpha.kubernetes.io/egress-bandwidth": "20M", }, }, }, @@ -3638,7 +3638,7 @@ func TestExtractBandwidthResources(t *testing.T) { pod: &api.Pod{ ObjectMeta: api.ObjectMeta{ Annotations: map[string]string{ - "kubernetes.io/ingress-bandwidth": "foo", + "net.alpha.kubernetes.io/ingress-bandwidth": "foo", }, }, },