From 1d2d5c61a80d1be19a4ef37693a2c4602062711e Mon Sep 17 00:00:00 2001 From: Andrew Or Date: Tue, 5 Aug 2014 13:05:43 -0700 Subject: [PATCH] Fix ports for standalone cluster mode --- core/src/main/scala/org/apache/spark/SparkConf.scala | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/SparkConf.scala b/core/src/main/scala/org/apache/spark/SparkConf.scala index eebb1f4102463..13f0bff7ee507 100644 --- a/core/src/main/scala/org/apache/spark/SparkConf.scala +++ b/core/src/main/scala/org/apache/spark/SparkConf.scala @@ -326,6 +326,11 @@ private[spark] object SparkConf { isAkkaConf(name) || name.startsWith("spark.akka") || name.startsWith("spark.auth") || - name == "spark.executor.port" + isSparkPortConf(name) } + + /** + * Return whether the given config is a Spark port config. + */ + def isSparkPortConf(name: String): Boolean = name.startsWith("spark.") && name.endsWith(".port") }