Try and avoid the PV/PVC delete/create race condition during PVTestSuite by iterating on the name

Author: holdenk

resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala

@@ -28,6 +28,8 @@ import org.apache.spark.deploy.k8s.integrationtest.KubernetesSuite._
 private[spark] trait PVTestsSuite { k8sSuite: KubernetesSuite =>
   import PVTestsSuite._
 
+  var i = 0
+
   private def setupLocalStorageClass(): Unit = {
     val scBuilder = new StorageClassBuilder()
       .withKind("StorageClass")
@@ -53,11 +55,13 @@ private[spark] trait PVTestsSuite { k8sSuite: KubernetesSuite =>
 
     setupLocalStorageClass()
 
+    i = i + 1
+
     val pvBuilder = new PersistentVolumeBuilder()
       .withKind("PersistentVolume")
       .withApiVersion("v1")
       .withNewMetadata()
-        .withName("test-local-pv")
+        .withName(f"{PV_NAME}-{i}")
       .endMetadata()
       .withNewSpec()
         .withCapacity(Map("storage" -> new Quantity("1Gi")).asJava)
@@ -81,7 +85,7 @@ private[spark] trait PVTestsSuite { k8sSuite: KubernetesSuite =>
       .withKind("PersistentVolumeClaim")
       .withApiVersion("v1")
       .withNewMetadata()
-        .withName(PVC_NAME)
+        .withName(f"{PVC_NAME}-{i}")
       .endMetadata()
       .withNewSpec()
         .withAccessModes("ReadWriteOnce")
@@ -105,13 +109,13 @@ private[spark] trait PVTestsSuite { k8sSuite: KubernetesSuite =>
     kubernetesTestComponents
       .kubernetesClient
       .persistentVolumeClaims()
-      .withName(PVC_NAME)
+      .withName(f"{PVC_NAME}-{i}")
       .delete()
 
     kubernetesTestComponents
       .kubernetesClient
       .persistentVolumes()
-      .withName(PV_NAME)
+      .withName(f"{PV_NAME}-{i}")
       .delete()
 
     kubernetesTestComponents