Github user adelbertc commented on a diff in the pull request:
https://github.com/apache/spark/pull/21884#discussion_r206360210
--- Diff:
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicDriverFeatureStep.scala
---
@@ -72,10 +72,25 @@ private[spark] class BasicDriverFeatureStep(
("cpu", new QuantityBuilder(false).withAmount(limitCores).build())
}
+ val driverPort = conf.sparkConf.getInt("spark.driver.port",
DEFAULT_DRIVER_PORT)
+ val driverBlockManagerPort = conf.sparkConf.getInt(
+ DRIVER_BLOCK_MANAGER_PORT.key,
+ DEFAULT_BLOCKMANAGER_PORT
+ )
val driverContainer = new ContainerBuilder(pod.container)
.withName(DRIVER_CONTAINER_NAME)
.withImage(driverContainerImage)
.withImagePullPolicy(conf.imagePullPolicy())
+ .addNewPort()
--- End diff --
Done
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
