diff options
| author | Nishkam Ravi <nishkamravi@gmail.com> | 2015-11-05 09:35:49 -0800 |
|---|---|---|
| committer | Marcelo Vanzin <vanzin@cloudera.com> | 2015-11-05 09:35:49 -0800 |
| commit | a4b5cefcf1a196e6b257e6127d6b43a7e50200ac (patch) | |
| tree | dc16e572a0deda8dfdda5ec609f0081bf1a63dc9 /core | |
| parent | 2e86cf1b01ae0ed69f72bf8054330440d432eeb7 (diff) | |
| download | spark-a4b5cefcf1a196e6b257e6127d6b43a7e50200ac.tar.gz spark-a4b5cefcf1a196e6b257e6127d6b43a7e50200ac.tar.bz2 spark-a4b5cefcf1a196e6b257e6127d6b43a7e50200ac.zip | |
[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 <nishkamravi@gmail.com>
Closes #9460 from nishkamravi2/master_akka.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/SparkConf.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkConf.scala b/core/src/main/scala/org/apache/spark/SparkConf.scala index f023e4b21c..19633a3ce6 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) } |