[SPARK-44996][K8S] VolcanoFeatureStep should not create `DefaultVol…

…canoClient` if not needed
dongjoon-hyun · Aug 29, 2023 · 9fad8f6 · 9fad8f6
1 parent 8e779d1
commit 9fad8f6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStep.scala b/...ernetes/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