github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

fix duplicate kube client

Browse Source
This commit is contained in:
astraw99 2021-09-19 11:30:15 +08:00
parent 25c7b6a2c7
commit f24e7ccf6a
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
View File

@ -432,17 +432,12 @@ func (nim *nodeInfoManager) tryInitializeCSINodeWithAnnotation(csiKubeClient cli
func (nim *nodeInfoManager) CreateCSINode() (*storagev1.CSINode, error) { func (nim *nodeInfoManager) CreateCSINode() (*storagev1.CSINode, error) {
kubeClient := nim.volumeHost.GetKubeClient()
if kubeClient == nil {
return nil, fmt.Errorf("error getting kube client")
}
csiKubeClient := nim.volumeHost.GetKubeClient() csiKubeClient := nim.volumeHost.GetKubeClient()
if csiKubeClient == nil { if csiKubeClient == nil {
return nil, fmt.Errorf("error getting CSI client") return nil, fmt.Errorf("error getting CSI client")
} }
node, err := kubeClient.CoreV1().Nodes().Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{}) node, err := csiKubeClient.CoreV1().Nodes().Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{})
if err != nil { if err != nil {
return nil, err return nil, err
} }