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()