diff --git a/test/e2e/node/pod_resize.go b/test/e2e/node/pod_resize.go index 03167d8a51f..464981e3019 100644 --- a/test/e2e/node/pod_resize.go +++ b/test/e2e/node/pod_resize.go @@ -1402,7 +1402,6 @@ func doPodResizeTests() { ginkgo.It(tc.name, func(ctx context.Context) { var testPod, patchedPod *v1.Pod var pErr error - var nodeName string tStamp := strconv.Itoa(time.Now().Nanosecond()) initDefaultResizePolicy(tc.containers) @@ -1413,10 +1412,14 @@ func doPodResizeTests() { nodes, err := e2enode.GetReadySchedulableNodes(context.Background(), f.ClientSet) framework.ExpectNoError(err) - nodeName = nodes.Items[0].Name - - addExtendedResource(f.ClientSet, nodeName, fakeExtendedResource, resource.MustParse("123")) - testPod.Spec.NodeName = nodeName + for _, node := range nodes.Items { + addExtendedResource(f.ClientSet, node.Name, fakeExtendedResource, resource.MustParse("123")) + } + defer func() { + for _, node := range nodes.Items { + removeExtendedResource(f.ClientSet, node.Name, fakeExtendedResource) + } + }() } ginkgo.By("creating pod") @@ -1480,10 +1483,6 @@ func doPodResizeTests() { ginkgo.By("deleting pod") err = e2epod.DeletePodWithWait(ctx, f.ClientSet, newPod) framework.ExpectNoError(err, "failed to delete pod") - - if tc.addExtendedResource { - removeExtendedResource(f.ClientSet, nodeName, fakeExtendedResource) - } }) } }