@@ -572,21 +572,14 @@ func (k *Bootstrapper) GenerateToken(cc config.ClusterConfig) (string, error) {
572
572
573
573
// DeleteCluster removes the components that were started earlier
574
574
func (k * Bootstrapper ) DeleteCluster (k8s config.KubernetesConfig ) error {
575
- cr , err := cruntime .New (cruntime.Config {Type : k8s .ContainerRuntime , Runner : k .c , Socket : k8s .CRISocket })
576
- if err != nil {
577
- return errors .Wrap (err , "runtime" )
578
- }
579
-
580
575
version , err := util .ParseKubernetesVersion (k8s .KubernetesVersion )
581
576
if err != nil {
582
577
return errors .Wrap (err , "parsing kubernetes version" )
583
578
}
584
579
585
- ka := bsutil .InvokeKubeadm (k8s .KubernetesVersion )
586
- sp := cr .SocketPath ()
587
- cmd := fmt .Sprintf ("%s reset --cri-socket %s --force" , ka , sp )
580
+ cmd := fmt .Sprintf ("%s reset --force" , bsutil .InvokeKubeadm (k8s .KubernetesVersion ))
588
581
if version .LT (semver .MustParse ("1.11.0" )) {
589
- cmd = fmt .Sprintf ("%s reset --cri-socket %s " , ka , sp )
582
+ cmd = fmt .Sprintf ("%s reset" , bsutil . InvokeKubeadm ( k8s . KubernetesVersion ) )
590
583
}
591
584
592
585
rr , derr := k .c .RunCmd (exec .Command ("/bin/bash" , "-c" , cmd ))
@@ -598,6 +591,11 @@ func (k *Bootstrapper) DeleteCluster(k8s config.KubernetesConfig) error {
598
591
glog .Warningf ("stop kubelet: %v" , err )
599
592
}
600
593
594
+ cr , err := cruntime .New (cruntime.Config {Type : k8s .ContainerRuntime , Runner : k .c , Socket : k8s .CRISocket })
595
+ if err != nil {
596
+ return errors .Wrap (err , "runtime" )
597
+ }
598
+
601
599
containers , err := cr .ListContainers (cruntime.ListOptions {Namespaces : []string {"kube-system" }})
602
600
if err != nil {
603
601
glog .Warningf ("unable to list kube-system containers: %v" , err )
0 commit comments