From 27f3005f3aea1a67651fa99f4b8919ca14531686 Mon Sep 17 00:00:00 2001 From: Kimoon Kim Date: Wed, 25 Jan 2017 18:17:30 -0800 Subject: [PATCH] Support spark.driver.extraJavaOptions (#48) --- .../deploy/rest/kubernetes/KubernetesSparkRestServer.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala index 08ddbaf5e50dc..4b8173381be3b 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala @@ -173,6 +173,10 @@ private[spark] class KubernetesSparkRestServer( val driverMemory = resolvedSparkProperties.getOrElse("spark.driver.memory", "1g") command += s"-Xms$driverMemory" command += s"-Xmx$driverMemory" + val extraJavaOpts = resolvedSparkProperties.get("spark.driver.extraJavaOptions") + .map(Utils.splitCommandString) + .getOrElse(Seq.empty) + command ++= extraJavaOpts command += mainClass command ++= appArgs val pb = new ProcessBuilder(command: _*).inheritIO()