diff --git a/cmd/kube-proxy/app/server.go b/cmd/kube-proxy/app/server.go index ec9065f2ef3..4aa86d0f803 100644 --- a/cmd/kube-proxy/app/server.go +++ b/cmd/kube-proxy/app/server.go @@ -413,7 +413,7 @@ func createClients(config componentconfig.ClientConnectionConfiguration, masterO return nil, nil, err } - return client, eventClient, nil + return client, eventClient.Core(), nil } // NewProxyServer returns a new ProxyServer. diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go index 4cd1f451f27..407cbc620f9 100644 --- a/cmd/kubelet/app/server.go +++ b/cmd/kubelet/app/server.go @@ -485,10 +485,12 @@ func run(s *options.KubeletServer, kubeDeps *kubelet.Dependencies) (err error) { eventClientConfig := *clientConfig eventClientConfig.QPS = float32(s.EventRecordQPS) eventClientConfig.Burst = int(s.EventBurst) - eventClient, err = clientgoclientset.NewForConfig(&eventClientConfig) + tmpClient, err := clientgoclientset.NewForConfig(&eventClientConfig) if err != nil { - glog.Warningf("Failed to create API Server client: %v", err) + glog.Warningf("Failed to create API Server client for Events: %v", err) } + eventClient = tmpClient.Core() + } else { switch { case s.RequireKubeConfig: