bootstrapper: remove unnecessary stat (#3202)

bootstrapper/internal/kubernetes/k8sapi/k8sutil.go

@@ -137,14 +137,11 @@ func (k *KubernetesUtil) InitCluster(
 	}
 
 	// Create static pods directory for all nodes (the Kubelets on the worker nodes also expect the path to exist)
-	if _, err := os.Stat("/etc/kubernetes/manifests"); err == nil {
-		// If the node rebooted after the static pod directory was created,
-		// the existing directory needs to be removed before we can
-		// try to init the cluster again.
-		log.Info("Removing existing static Pod directory /etc/kubernetes/manifests")
-		if err := os.RemoveAll("/etc/kubernetes/manifests"); err != nil {
-			return nil, fmt.Errorf("removing static pods directory: %w", err)
-		}
+	// If the node rebooted after the static pod directory was created,
+	// the existing directory needs to be removed before we can
+	// try to init the cluster again.
+	if err := os.RemoveAll("/etc/kubernetes/manifests"); err != nil {
+		return nil, fmt.Errorf("removing static pods directory: %w", err)
 	}
 	log.Info("Creating static Pod directory /etc/kubernetes/manifests")
 	if err := os.MkdirAll("/etc/kubernetes/manifests", os.ModePerm); err != nil {
@@ -209,14 +206,11 @@ func (k *KubernetesUtil) JoinCluster(ctx context.Context, joinConfig []byte, log
 	}
 
 	// Create static pods directory for all nodes (the Kubelets on the worker nodes also expect the path to exist)
-	if _, err := os.Stat("/etc/kubernetes/manifests"); err == nil {
-		// If the node rebooted after the static pod directory was created, for example
-		// if a failure during an upgrade occurred, the existing directory needs to be
-		// removed before we can try to join the cluster again.
-		log.Info("Removing existing static Pod directory /etc/kubernetes/manifests")
-		if err := os.RemoveAll("/etc/kubernetes/manifests"); err != nil {
-			return fmt.Errorf("removing static pods directory: %w", err)
-		}
+	// If the node rebooted after the static pod directory was created, for example
+	// if a failure during an upgrade occurred, the existing directory needs to be
+	// removed before we can try to join the cluster again.
+	if err := os.RemoveAll("/etc/kubernetes/manifests"); err != nil {
+		return fmt.Errorf("removing static pods directory: %w", err)
 	}
 	log.Info("Creating static Pod directory /etc/kubernetes/manifests")
 	if err := os.MkdirAll("/etc/kubernetes/manifests", os.ModePerm); err != nil {