diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index c6fe21cf028..654728be670 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -1789,7 +1789,6 @@ func (kl *Kubelet) syncLoopIteration(configCh <-chan kubetypes.PodUpdate, handle // takes place only after kubelet calls the update handler to process // the update to ensure the internal pod cache is up-to-date. kl.sourcesReady.AddSource(u.Source) - case e := <-plegCh: if isSyncPodWorthy(e) { // PLEG event for a pod; sync it. diff --git a/pkg/kubelet/kubelet_node_status.go b/pkg/kubelet/kubelet_node_status.go index c25356b6023..2148851cb81 100644 --- a/pkg/kubelet/kubelet_node_status.go +++ b/pkg/kubelet/kubelet_node_status.go @@ -565,7 +565,6 @@ func (kl *Kubelet) setNodeStatusVersionInfo(node *v1.Node) { // TODO: kube-proxy might be different version from kubelet in the future node.Status.NodeInfo.KubeProxyVersion = version.Get().String() } - } // Set daemonEndpoints for the node. diff --git a/staging/src/k8s.io/client-go/util/workqueue/delaying_queue_test.go b/staging/src/k8s.io/client-go/util/workqueue/delaying_queue_test.go index 1b7661064a2..78c92ad4dad 100644 --- a/staging/src/k8s.io/client-go/util/workqueue/delaying_queue_test.go +++ b/staging/src/k8s.io/client-go/util/workqueue/delaying_queue_test.go @@ -174,7 +174,6 @@ func TestAddTwoFireEarly(t *testing.T) { if !reflect.DeepEqual(item, third) { t.Errorf("expected %v, got %v", third, item) } - } func TestCopyShifting(t *testing.T) {