You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by va...@apache.org on 2015/11/05 18:36:07 UTC
spark git commit: [SPARK-11501][CORE][YARN] Propagate spark.rpc
config to executors
Repository: spark
Updated Branches:
refs/heads/master 2e86cf1b0 -> a4b5cefcf
[SPARK-11501][CORE][YARN] Propagate spark.rpc config to executors
spark.rpc is supposed to be configurable but is not currently (doesn't get propagated to executors because RpcEnv.create is done before driver properties are fetched).
Author: Nishkam Ravi <ni...@gmail.com>
Closes #9460 from nishkamravi2/master_akka.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/a4b5cefc
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/a4b5cefc
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/a4b5cefc
Branch: refs/heads/master
Commit: a4b5cefcf1a196e6b257e6127d6b43a7e50200ac
Parents: 2e86cf1
Author: Nishkam Ravi <ni...@gmail.com>
Authored: Thu Nov 5 09:35:49 2015 -0800
Committer: Marcelo Vanzin <va...@cloudera.com>
Committed: Thu Nov 5 09:35:49 2015 -0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/SparkConf.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/a4b5cefc/core/src/main/scala/org/apache/spark/SparkConf.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/SparkConf.scala b/core/src/main/scala/org/apache/spark/SparkConf.scala
index f023e4b..19633a3 100644
--- a/core/src/main/scala/org/apache/spark/SparkConf.scala
+++ b/core/src/main/scala/org/apache/spark/SparkConf.scala
@@ -629,6 +629,7 @@ private[spark] object SparkConf extends Logging {
name.startsWith("spark.akka") ||
(name.startsWith("spark.auth") && name != SecurityManager.SPARK_AUTH_SECRET_CONF) ||
name.startsWith("spark.ssl") ||
+ name.startsWith("spark.rpc") ||
isSparkPortConf(name)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org