mirror of https://github.com/k3s-io/k3s
Explicitly use Core() client when creating eventClint
parent
c35bf2aa7b
commit
45b47c7faa
|
@ -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.
|
||||
|
|
|
@ -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:
|
||||
|
|
Loading…
Reference in New Issue