Merge pull request #1041 from zhangzujian/fix-sts

fix StatefulSet down scale

Merge pull request #1041 from zhangzujian/fix-sts
fix StatefulSet down scale
cf4ff8cd · 张祖建 · GitHub · b765c456 · 1f5719a5 · cf4ff8cd
Unverified Commit cf4ff8cd authored 3 years ago by 张祖建 Committed by GitHub 3 years ago
Hide whitespace changes
Inline Side-by-side

Showing

with 1 addition and 5 deletions
+1 -5
--- a/pkg/controller/pod.go
+++ b/pkg/controller/pod.go
@@ -826,11 +826,7 @@ func isStatefulSetPodToDel(c kubernetes.Interface, pod *v1.Pod, statefulSetName
 		return false
 	}

-	if index >= int64(*ss.Spec.Replicas) {
-		return true
-	}
-
-	return false
+	return index >= int64(*ss.Spec.Replicas) && index >= int64(ss.Status.Replicas)
 }

 func getNodeTunlIP(node *v1.Node) ([]net.IP, error) {