From 398777f26120d94aae3941e2d785ecc37e6ea6fa Mon Sep 17 00:00:00 2001 From: Michelle Au Date: Tue, 12 Mar 2019 16:09:02 -0700 Subject: [PATCH] ignore kubeclient nil in csi plugin init --- pkg/volume/csi/csi_plugin.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/pkg/volume/csi/csi_plugin.go b/pkg/volume/csi/csi_plugin.go index 54bdc20ac0..358ccf5ac8 100644 --- a/pkg/volume/csi/csi_plugin.go +++ b/pkg/volume/csi/csi_plugin.go @@ -207,13 +207,14 @@ func (p *csiPlugin) Init(host volume.VolumeHost) error { if utilfeature.DefaultFeatureGate.Enabled(features.CSIDriverRegistry) { csiClient := host.GetKubeClient() if csiClient == nil { - return errors.New("unable to get Kubernetes client") + klog.Warning(log("kubeclient not set, assuming standalone kubelet")) + } else { + // Start informer for CSIDrivers. + factory := csiapiinformer.NewSharedInformerFactory(csiClient, csiResyncPeriod) + p.csiDriverInformer = factory.Storage().V1beta1().CSIDrivers() + p.csiDriverLister = p.csiDriverInformer.Lister() + go factory.Start(wait.NeverStop) } - // Start informer for CSIDrivers. - factory := csiapiinformer.NewSharedInformerFactory(csiClient, csiResyncPeriod) - p.csiDriverInformer = factory.Storage().V1beta1().CSIDrivers() - p.csiDriverLister = p.csiDriverInformer.Lister() - go factory.Start(wait.NeverStop) } // Initializing the label management channels