github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 12:43:23 +00:00
Code Issues Projects Releases Wiki Activity

kubeadm: fix reset error logging.

Browse Source
This commit is contained in:
Paulo Pires 2017-02-02 10:54:18 +00:00
parent 0477100f98
commit 68113cacf2
No known key found for this signature in database
GPG Key ID: F3F6ED5C522EAA71
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
cmd/kubeadm/app/cmd/reset.go
View File

@ -144,7 +144,6 @@ func (r *Reset) Run(out io.Writer) error {
} }
func drainAndRemoveNode(removeNode bool) error { func drainAndRemoveNode(removeNode bool) error {
hostname, err := os.Hostname() hostname, err := os.Hostname()
if err != nil { if err != nil {
return fmt.Errorf("failed to detect node hostname") return fmt.Errorf("failed to detect node hostname")
@ -156,24 +155,26 @@ func drainAndRemoveNode(removeNode bool) error {
getNodesCmd := fmt.Sprintf("kubectl --kubeconfig %s get nodes | grep %s", kubeConfigPath, hostname) getNodesCmd := fmt.Sprintf("kubectl --kubeconfig %s get nodes | grep %s", kubeConfigPath, hostname)
output, err := exec.Command("sh", "-c", getNodesCmd).Output() output, err := exec.Command("sh", "-c", getNodesCmd).Output()
if err != nil || len(output) == 0 { if err != nil {
// kubeadm shouldn't drain and/or remove the node when it doesn't exist anymore // kubeadm shouldn't drain and/or remove the node when it doesn't exist anymore
return nil return fmt.Errorf("failed to list nodes: %v", err)
}
if len(output) == 0 {
return fmt.Errorf("list nodes request returned zero entries")
} }
fmt.Printf("[reset] Draining node: %q\n", hostname) fmt.Printf("[reset] Draining node: %q\n", hostname)
output, err = exec.Command("kubectl", "--kubeconfig", kubeConfigPath, "drain", hostname, "--delete-local-data", "--force", "--ignore-daemonsets").Output() _, err = exec.Command("kubectl", "--kubeconfig", kubeConfigPath, "drain", hostname, "--delete-local-data", "--force", "--ignore-daemonsets").Output()
if err != nil { if err != nil {
return fmt.Errorf("failed to drain node %q [%s]", hostname, output) return fmt.Errorf("failed to drain node %q: %v", hostname, err)
} }
if removeNode { if removeNode {
fmt.Printf("[reset] Removing node: %q\n", hostname) fmt.Printf("[reset] Removing node: %q\n", hostname)
_, err = exec.Command("kubectl", "--kubeconfig", kubeConfigPath, "delete", "node", hostname).Output()
output, err = exec.Command("kubectl", "--kubeconfig", kubeConfigPath, "delete", "node", hostname).Output()
if err != nil { if err != nil {
return fmt.Errorf("failed to remove node %q [%s]", hostname, output) return fmt.Errorf("failed to remove node %q: %v", hostname, err)
} }
} }