@@ -31,15 +31,13 @@ import (
3131 "go.uber.org/zap"
3232 v1 "k8s.io/api/core/v1"
3333 "k8s.io/apimachinery/pkg/api/resource"
34- "k8s.io/apimachinery/pkg/util/wait"
35- "k8s.io/apimachinery/pkg/version"
3634 "k8s.io/client-go/informers"
3735 informersv1 "k8s.io/client-go/informers/core/v1"
3836 "k8s.io/client-go/kubernetes"
3937 listersv1 "k8s.io/client-go/listers/core/v1"
4038 "k8s.io/client-go/tools/cache"
4139 "k8s.io/client-go/tools/clientcmd"
42- "sigs.k8s.io/sig-storage-lib-external-provisioner/v6 /controller"
40+ "sigs.k8s.io/sig-storage-lib-external-provisioner/v8 /controller"
4341)
4442
4543const (
@@ -242,17 +240,6 @@ func Run(logger *zap.SugaredLogger, kubeconfig string, master string, minVolumeS
242240 return errors .Wrapf (err , "failed to create Kubernetes client" )
243241 }
244242
245- // The controller needs to know what the server version is because out-of-tree
246- // provisioners aren't officially supported until 1.5
247- var serverVersion * version.Info
248- err = wait .PollUntil (15 * time .Second , func () (done bool , err error ) {
249- serverVersion , err = clientset .Discovery ().ServerVersion ()
250- if err != nil {
251- logger .With (zap .Error (err )).Info ("failed to get kube-apiserver version, will retry again" )
252- return false , nil
253- }
254- return true , nil
255- }, stopCh )
256243 if err != nil {
257244 return errors .Wrapf (err , "failed to get kube-apiserver version" )
258245 }
@@ -285,7 +272,6 @@ func Run(logger *zap.SugaredLogger, kubeconfig string, master string, minVolumeS
285272 clientset ,
286273 provisionerType ,
287274 ociProvisioner ,
288- serverVersion .GitVersion ,
289275 controller .ResyncPeriod (resyncPeriod ),
290276 controller .ExponentialBackOffOnError (exponentialBackOffOnError ),
291277 controller .FailedProvisionThreshold (failedRetryThreshold ),
0 commit comments