Skip to content
This repository was archived by the owner on Jan 9, 2020. It is now read-only.

Commit c47ce5c

Browse files
kimoonkimfoxish
authored andcommitted
Support spark.driver.extraJavaOptions (#48)
1 parent 3c6eed8 commit c47ce5c

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,10 @@ private[spark] class KubernetesSparkRestServer(
173173
val driverMemory = resolvedSparkProperties.getOrElse("spark.driver.memory", "1g")
174174
command += s"-Xms$driverMemory"
175175
command += s"-Xmx$driverMemory"
176+
val extraJavaOpts = resolvedSparkProperties.get("spark.driver.extraJavaOptions")
177+
.map(Utils.splitCommandString)
178+
.getOrElse(Seq.empty)
179+
command ++= extraJavaOpts
176180
command += mainClass
177181
command ++= appArgs
178182
val pb = new ProcessBuilder(command: _*).inheritIO()

0 commit comments

Comments
 (0)