From 45b47c7faa78d8d4f66f3de4218baad4a32397ca Mon Sep 17 00:00:00 2001
From: gmarek <gmarek@google.com>
Date: Fri, 21 Jul 2017 11:22:56 +0200
Subject: [PATCH] Explicitly use Core() client when creating eventClint

---
 cmd/kube-proxy/app/server.go | 2 +-
 cmd/kubelet/app/server.go    | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

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: