diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStep.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStep.scala index 1a06f7ee0bf6f..314550713ef16 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStep.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStep.scala @@ -46,7 +46,7 @@ private[spark] class VolcanoFeatureStep extends KubernetesDriverCustomFeatureCon "for executor.") return Seq.empty } - val client = new DefaultVolcanoClient + lazy val client = new DefaultVolcanoClient val template = kubernetesConf.getOption(POD_GROUP_TEMPLATE_FILE_KEY) val pg = template.map(client.podGroups.load(_).item).getOrElse(new PodGroup()) var metadata = pg.getMetadata