Sok3t/descheduler
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/descheduler.git synced 2026-01-28 06:29:29 +01:00
Code Packages Releases Activity

remove some logic useless

Browse Source
This commit is contained in:
lucming
2023-02-16 17:25:00 +08:00
parent 463158f7dc
commit 02b1e8b8b9
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/framework/plugins/removepodsviolatingnodetaints/node_taint.go
View File

@@ -105,7 +105,6 @@ func (d *RemovePodsViolatingNodeTaints) Deschedule(ctx context.Context, nodes []
} }
} }
totalPods := len(pods) totalPods := len(pods)
skipNode := false
for i := 0; i < totalPods; i++ { for i := 0; i < totalPods; i++ {
if !utils.TolerationsTolerateTaintsWithFilter( if !utils.TolerationsTolerateTaintsWithFilter(
pods[i].Spec.Tolerations, pods[i].Spec.Tolerations,
@@ -115,14 +114,11 @@ func (d *RemovePodsViolatingNodeTaints) Deschedule(ctx context.Context, nodes []
klog.V(2).InfoS("Not all taints with NoSchedule effect are tolerated after update for pod on node", "pod", klog.KObj(pods[i]), "node", klog.KObj(node)) klog.V(2).InfoS("Not all taints with NoSchedule effect are tolerated after update for pod on node", "pod", klog.KObj(pods[i]), "node", klog.KObj(node))
d.handle.Evictor().Evict(ctx, pods[i], evictions.EvictOptions{}) d.handle.Evictor().Evict(ctx, pods[i], evictions.EvictOptions{})
if d.handle.Evictor().NodeLimitExceeded(node) { if d.handle.Evictor().NodeLimitExceeded(node) {
skipNode = true
break break
} }
} }
} }
if skipNode {
continue
}
} }
return nil return nil
} }