diff --git a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala index 0362b348e139a..34c7907707c7a 100644 --- a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala +++ b/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