fix: upgrade k8s version failed on non default ssh port (issue #3069) (…

…#3434) Signed-off-by: yangxg <yangxggo@163.com>
labring · Jun 29, 2023 · 02ce79b · 02ce79b
1 parent fa3f2db
commit 02ce79b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/runtime/upgrade.go b/pkg/runtime/upgrade.go
@@ -55,11 +55,11 @@ func (k *KubeadmRuntime) upgradeCluster(version string) error {
 	}
 	//upgrade other control-planes and worker nodes
 	var upgradeNodes []string
-	for _, ip := range append(k.getMasterIPList(), k.getNodeIPList()...) {
-		if ip == k.getMaster0IP() {
+	for _, node := range append(k.getMasterIPAndPortList(), k.getNodeIPAndPortList()...) {
+		if node == k.getMaster0IPAndPort() {
 			continue
 		}
-		upgradeNodes = append(upgradeNodes, ip)
+		upgradeNodes = append(upgradeNodes, node)
 	}
 	logger.Info("start to upgrade other control-planes and worker nodes")
 	return k.upgradeOtherNodes(upgradeNodes, version)