diff --git a/test/e2e/storage/flexvolume.go b/test/e2e/storage/flexvolume.go index 0065c406eb3..ce5efba1597 100644 --- a/test/e2e/storage/flexvolume.go +++ b/test/e2e/storage/flexvolume.go @@ -26,7 +26,6 @@ import ( "github.com/onsi/ginkgo/v2" v1 "k8s.io/api/core/v1" - apierrors "k8s.io/apimachinery/pkg/api/errors" clientset "k8s.io/client-go/kubernetes" "k8s.io/kubernetes/test/e2e/framework" e2enode "k8s.io/kubernetes/test/e2e/framework/node" @@ -197,11 +196,6 @@ var _ = utils.SIGDescribe("Flexvolumes", func() { testFlexVolume(ctx, driverInstallAs, config, f) - ginkgo.By("waiting for flex client pod to terminate") - if err := e2epod.WaitForPodTerminatedInNamespace(ctx, f.ClientSet, config.Prefix+"-client", "", f.Namespace.Name); !apierrors.IsNotFound(err) { - framework.ExpectNoError(err, "Failed to wait client pod terminated: %v", err) - } - ginkgo.By(fmt.Sprintf("uninstalling flexvolume %s from node %s", driverInstallAs, node.Name)) uninstallFlex(ctx, cs, node, "k8s", driverInstallAs) }) @@ -217,11 +211,6 @@ var _ = utils.SIGDescribe("Flexvolumes", func() { testFlexVolume(ctx, driverInstallAs, config, f) - ginkgo.By("waiting for flex client pod to terminate") - if err := e2epod.WaitForPodTerminatedInNamespace(ctx, f.ClientSet, config.Prefix+"-client", "", f.Namespace.Name); !apierrors.IsNotFound(err) { - framework.ExpectNoError(err, "Failed to wait client pod terminated: %v", err) - } - // Detach might occur after pod deletion. Wait before deleting driver. time.Sleep(detachTimeout)