From f24e7ccf6a633bdc474380dc579a95d6974b00b2 Mon Sep 17 00:00:00 2001 From: astraw99 Date: Sun, 19 Sep 2021 11:30:15 +0800 Subject: [PATCH] fix duplicate kube client --- pkg/volume/csi/nodeinfomanager/nodeinfomanager.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go b/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go index d7c709eb5ba..ff17155dd43 100644 --- a/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go +++ b/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go @@ -432,17 +432,12 @@ func (nim *nodeInfoManager) tryInitializeCSINodeWithAnnotation(csiKubeClient cli 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() if csiKubeClient == nil { 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 { return nil, err }