Merge pull request #87361 from zhouya0/fix_kubectl_drain_ignore_daemonsets_and_ohters

Fix kubectl drain ignore daemonsets and others

Kubernetes-commit: a330defda3bb663138879b6b8d96752b669a22a6
This commit is contained in:
Kubernetes Publisher 2020-02-12 02:23:16 -08:00
commit 80a3ad3579
2 changed files with 9 additions and 8 deletions

View File

@ -867,7 +867,7 @@ func TestDrain(t *testing.T) {
switch {
case recovered != nil && !sawFatal:
t.Fatalf("got panic: %v", recovered)
case test.expectDelete && test.expectFatal && !sawFatal:
case test.expectFatal && !sawFatal:
t.Fatalf("%s: unexpected non-error when using %s", test.description, currMethod)
case !test.expectFatal && sawFatal:
t.Fatalf("%s: unexpected error when using %s: %s", test.description, currMethod, fatalMsg)
@ -903,7 +903,7 @@ func TestDrain(t *testing.T) {
t.Fatalf("%s: same pod deleted %d times and evicted %d times", test.description, deletions, evictions)
}
if test.expectDelete && len(test.expectWarning) > 0 {
if len(test.expectWarning) > 0 {
if len(errBuf.String()) == 0 {
t.Fatalf("%s: expected warning, but found no stderr output", test.description)
}

View File

@ -180,12 +180,13 @@ func (d *Helper) GetPodsForDeletion(nodeName string) (*podDeleteList, []error) {
break
}
}
if status.delete {
pods = append(pods, podDelete{
pod: pod,
status: status,
})
}
// Add the pod to podDeleteList no matter what podDeleteStatus is,
// those pods whose podDeleteStatus is false like DaemonSet will
// be catched by list.errors()
pods = append(pods, podDelete{
pod: pod,
status: status,
})
}
list := &podDeleteList{items: pods}