From 9d9c841b3528e0806280a58a0a8acaa456aa6e44 Mon Sep 17 00:00:00 2001 From: Yinan Li Date: Fri, 22 Dec 2017 14:51:52 -0800 Subject: [PATCH] Updated names of two configuration properties --- .../scala/org/apache/spark/deploy/k8s/Config.scala | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/Config.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/Config.scala index 0655be0ad80e5..e50a2ac4ffcf8 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/Config.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/Config.scala @@ -152,17 +152,16 @@ private[spark] object Config extends Logging { .createOptional val INIT_CONTAINER_MOUNT_TIMEOUT = - ConfigBuilder("spark.kubernetes.mountDependencies.mountTimeout") - .doc("Timeout before aborting the attempt to download and unpack local dependencies from " + - "remote locations and the resource staging server when initializing the driver and " + - "executor pods.") + ConfigBuilder("spark.kubernetes.mountDependencies.timeout") + .doc("Timeout before aborting the attempt to download and unpack dependencies from remote " + + "locations into the driver and executor pods.") .timeConf(TimeUnit.MINUTES) .createWithDefault(5) val INIT_CONTAINER_MAX_THREAD_POOL_SIZE = - ConfigBuilder("spark.kubernetes.initContainer.maxThreadPoolSize") - .doc("Maximum size of the thread pool in the init-container for downloading remote " + - "dependencies.") + ConfigBuilder("spark.kubernetes.mountDependencies.maxSimultaneousDownloads") + .doc("Maximum number of remote dependencies to download simultaneously in a driver or " + + "executor pod.") .intConf .createWithDefault(5)