Skip to content

Commit 4c944c4

Browse files
committed
Manage args differently.
1 parent 67e9ca1 commit 4c944c4

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicDriverFeatureStep.scala

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,8 +96,12 @@ private[spark] class BasicDriverFeatureStep(
9696
// The user application jar is merged into the spark.jars list and managed through that
9797
// property, so there is no need to reference it explicitly here.
9898
.addToArgs(SparkLauncher.NO_RESOURCE)
99-
.addToArgs(kubernetesConf.roleSpecificConf.appArgs: _*)
10099
.build()
100+
val driverContainerWithArgs = if (kubernetesConf.roleSpecificConf.appArgs.nonEmpty) {
101+
new ContainerBuilder(driverContainer)
102+
.addToArgs(kubernetesConf.roleSpecificConf.appArgs: _*)
103+
.build()
104+
} else driverContainer
101105

102106
val driverPod = new PodBuilder(pod.pod)
103107
.editOrNewMetadata()
@@ -110,7 +114,7 @@ private[spark] class BasicDriverFeatureStep(
110114
.withNodeSelector(kubernetesConf.nodeSelector().asJava)
111115
.endSpec()
112116
.build()
113-
SparkPod(driverPod, driverContainer)
117+
SparkPod(driverPod, driverContainerWithArgs)
114118
}
115119

116120
override def getAdditionalPodSystemProperties(): Map[String, String] = {

0 commit comments

Comments
 (0)