controller: consider StatefulSet's ordinals

Signed-off-by: zhangzujian <[email protected]>
kubeovn · Feb 6, 2025 · d26bafb · d26bafb
1 parent 61ae787
commit d26bafb
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/controller/pod.go b/pkg/controller/pod.go
@@ -1267,7 +1267,11 @@ func isStatefulSetPodToDel(c kubernetes.Interface, pod *v1.Pod, statefulSetName
 		return false
 	}
 	// down scaled
-	if index >= int64(*sts.Spec.Replicas) {
+	var ordinalsStart int64
+	if sts.Spec.Ordinals != nil {
+		ordinalsStart = int64(sts.Spec.Ordinals.Start)
+	}
+	if index >= ordinalsStart+int64(*sts.Spec.Replicas) {
 		klog.Infof("statefulset %s is down scaled", statefulSetName)
 		return true
 	}