From 7aa496c10d88248a36db6b41857c20b070882586 Mon Sep 17 00:00:00 2001 From: Kimoon Kim Date: Wed, 25 Jan 2017 14:43:03 -0800 Subject: [PATCH] Support spark.driver.extraJavaOptions --- .../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 08ddbaf5e50d..4b8173381be3 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()