Fix ports for standalone cluster mode

apache · Aug 5, 2014 · 1d2d5c6 · 1d2d5c6
1 parent cb3be88
commit 1d2d5c6
Showing 1 changed file with 6 additions and 1 deletion.
diff --git 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")
 }