diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesClusterSchedulerBackend.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesClusterSchedulerBackend.scala index 43c6597362e41..985b8b7bef051 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesClusterSchedulerBackend.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesClusterSchedulerBackend.scala @@ -141,11 +141,13 @@ private[spark] class KubernetesClusterSchedulerBackend( } } - Utils.tryLogNonFatalError { - kubernetesClient - .persistentVolumeClaims() - .withLabel(SPARK_APP_ID_LABEL, applicationId()) - .delete() + if (conf.get(KUBERNETES_DRIVER_OWN_PVC)) { + Utils.tryLogNonFatalError { + kubernetesClient + .persistentVolumeClaims() + .withLabel(SPARK_APP_ID_LABEL, applicationId()) + .delete() + } } if (shouldDeleteExecutors) {