Support specify CPU cores for driver pod (apache#207)

lins05 · Mar 30, 2017 · 35a5e32 · 35a5e32
1 parent 3254246
commit 35a5e32
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...e-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala b/...e-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala
@@ -64,6 +64,9 @@ private[spark] class Client(
     .map(_.split(","))
     .getOrElse(Array.empty[String])
 
+  // CPU settings
+  private val driverCpuCores = sparkConf.getOption("spark.driver.cores").getOrElse("1")
+
   // Memory settings
   private val driverMemoryMb = sparkConf.get(org.apache.spark.internal.config.DRIVER_MEMORY)
   private val driverSubmitServerMemoryMb = sparkConf.get(KUBERNETES_DRIVER_SUBMIT_SERVER_MEMORY)
@@ -431,6 +434,9 @@ private[spark] class Client(
       .withPath("/v1/submissions/ping")
       .withNewPort(SUBMISSION_SERVER_PORT_NAME)
       .build()
+    val driverCpuQuantity = new QuantityBuilder(false)
+      .withAmount(driverCpuCores)
+      .build()
     val driverMemoryQuantity = new QuantityBuilder(false)
       .withAmount(s"${driverContainerMemoryMb}M")
       .build()
@@ -478,6 +484,8 @@ private[spark] class Client(
             .endEnv()
           .addToEnv(sslConfiguration.sslPodEnvVars: _*)
           .withNewResources()
+            .addToRequests("cpu", driverCpuQuantity)
+            .addToLimits("cpu", driverCpuQuantity)
             .addToRequests("memory", driverMemoryQuantity)
             .addToLimits("memory", driverMemoryLimitQuantity)
             .endResources()