Skip to content
This repository was archived by the owner on Jan 9, 2020. It is now read-only.

Commit 3b587b4

Browse files
committed
Removed unused parameter in parsePrefixedKeyValuePairs
1 parent b75b413 commit 3b587b4

File tree

2 files changed

+4
-9
lines changed

2 files changed

+4
-9
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/ConfigurationUtils.scala

+1-3
Original file line numberDiff line numberDiff line change
@@ -27,13 +27,11 @@ private[spark] object ConfigurationUtils {
2727
*
2828
* @param sparkConf Spark configuration
2929
* @param prefix the given property name prefix
30-
* @param configType a descriptive note on the type of entities of interest
3130
* @return a Map storing the configuration property keys and values
3231
*/
3332
def parsePrefixedKeyValuePairs(
3433
sparkConf: SparkConf,
35-
prefix: String,
36-
configType: String): Map[String, String] = {
34+
prefix: String): Map[String, String] = {
3735
sparkConf.getAllWithPrefix(prefix).toMap
3836
}
3937

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/ExecutorPodFactory.scala

+3-6
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,7 @@ private[spark] class ExecutorPodFactoryImpl(sparkConf: SparkConf)
5353

5454
private val executorLabels = ConfigurationUtils.parsePrefixedKeyValuePairs(
5555
sparkConf,
56-
KUBERNETES_EXECUTOR_LABEL_PREFIX,
57-
"executor label")
56+
KUBERNETES_EXECUTOR_LABEL_PREFIX)
5857
require(
5958
!executorLabels.contains(SPARK_APP_ID_LABEL),
6059
s"Custom executor labels cannot contain $SPARK_APP_ID_LABEL as it is reserved for Spark.")
@@ -69,13 +68,11 @@ private[spark] class ExecutorPodFactoryImpl(sparkConf: SparkConf)
6968
private val executorAnnotations =
7069
ConfigurationUtils.parsePrefixedKeyValuePairs(
7170
sparkConf,
72-
KUBERNETES_EXECUTOR_ANNOTATION_PREFIX,
73-
"executor annotation")
71+
KUBERNETES_EXECUTOR_ANNOTATION_PREFIX)
7472
private val nodeSelector =
7573
ConfigurationUtils.parsePrefixedKeyValuePairs(
7674
sparkConf,
77-
KUBERNETES_NODE_SELECTOR_PREFIX,
78-
"node selector")
75+
KUBERNETES_NODE_SELECTOR_PREFIX)
7976

8077
private val executorDockerImage = sparkConf.get(EXECUTOR_DOCKER_IMAGE)
8178
private val dockerImagePullPolicy = sparkConf.get(DOCKER_IMAGE_PULL_POLICY)

0 commit comments

Comments
 (0)