diff --git a/test/e2e/storage/flexvolume.go b/test/e2e/storage/flexvolume.go index 8544cd00b4e..3eed7219938 100644 --- a/test/e2e/storage/flexvolume.go +++ b/test/e2e/storage/flexvolume.go @@ -47,6 +47,7 @@ const ( gciVolumePluginDir = "/home/kubernetes/flexvolume" gciVolumePluginDirLegacy = "/etc/srv/kubernetes/kubelet-plugins/volume/exec" gciVolumePluginDirVersion = "1.10.0" + detachTimeout = 10 * time.Second ) // testFlexVolume tests that a client pod using a given flexvolume driver @@ -253,6 +254,9 @@ var _ = utils.SIGDescribe("Flexvolumes", func() { framework.ExpectNoError(err, "Failed to wait client pod terminated: %v", err) } + // Detach might occur after pod deletion. Wait before deleting driver. + time.Sleep(detachTimeout) + By(fmt.Sprintf("uninstalling flexvolume %s from node %s", driverInstallAs, node.Name)) uninstallFlex(cs, &node, "k8s", driverInstallAs) By(fmt.Sprintf("uninstalling flexvolume %s from master", driverInstallAs))