aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/scala/org/apache/spark/SparkConf.scala
diff options
context:
space:
mode:
authorShixiong Zhu <shixiong@databricks.com>2015-12-31 00:15:55 -0800
committerReynold Xin <rxin@databricks.com>2015-12-31 00:15:55 -0800
commit4f5a24d7e73104771f233af041eeba4f41675974 (patch)
tree57f3c139e679e476c97189ccc6d967919b3ed61d /core/src/main/scala/org/apache/spark/SparkConf.scala
parente6c77874b915691dead91e8d96ad9f58ba3a73db (diff)
downloadspark-4f5a24d7e73104771f233af041eeba4f41675974.tar.gz
spark-4f5a24d7e73104771f233af041eeba4f41675974.tar.bz2
spark-4f5a24d7e73104771f233af041eeba4f41675974.zip
[SPARK-7995][SPARK-6280][CORE] Remove AkkaRpcEnv and remove systemName from setupEndpointRef
### Remove AkkaRpcEnv Keep `SparkEnv.actorSystem` because Streaming still uses it. Will remove it and AkkaUtils after refactoring Streaming actorStream API. ### Remove systemName There are 2 places using `systemName`: * `RpcEnvConfig.name`. Actually, although it's used as `systemName` in `AkkaRpcEnv`, `NettyRpcEnv` uses it as the service name to output the log `Successfully started service *** on port ***`. Since the service name in log is useful, I keep `RpcEnvConfig.name`. * `def setupEndpointRef(systemName: String, address: RpcAddress, endpointName: String)`. Each `ActorSystem` has a `systemName`. Akka requires `systemName` in its URI and will refuse a connection if `systemName` is not matched. However, `NettyRpcEnv` doesn't use it. So we can remove `systemName` from `setupEndpointRef` since we are removing `AkkaRpcEnv`. ### Remove RpcEnv.uriOf `uriOf` exists because Akka uses different URI formats for with and without authentication, e.g., `akka.ssl.tcp...` and `akka.tcp://...`. But `NettyRpcEnv` uses the same format. So it's not necessary after removing `AkkaRpcEnv`. Author: Shixiong Zhu <shixiong@databricks.com> Closes #10459 from zsxwing/remove-akka-rpc-env.
Diffstat (limited to 'core/src/main/scala/org/apache/spark/SparkConf.scala')
-rw-r--r--core/src/main/scala/org/apache/spark/SparkConf.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkConf.scala b/core/src/main/scala/org/apache/spark/SparkConf.scala
index d3384fb297..ff2c4c34c0 100644
--- a/core/src/main/scala/org/apache/spark/SparkConf.scala
+++ b/core/src/main/scala/org/apache/spark/SparkConf.scala
@@ -544,7 +544,8 @@ private[spark] object SparkConf extends Logging {
DeprecatedConfig("spark.kryoserializer.buffer.mb", "1.4",
"Please use spark.kryoserializer.buffer instead. The default value for " +
"spark.kryoserializer.buffer.mb was previously specified as '0.064'. Fractional values " +
- "are no longer accepted. To specify the equivalent now, one may use '64k'.")
+ "are no longer accepted. To specify the equivalent now, one may use '64k'."),
+ DeprecatedConfig("spark.rpc", "2.0", "Not used any more.")
)
Map(configs.map { cfg => (cfg.key -> cfg) } : _*)