We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5a6305f commit ffe4b97Copy full SHA for ffe4b97
core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
@@ -38,8 +38,6 @@ private[spark] object RpcEnv {
38
// Add more RpcEnv implementations here
39
val rpcEnvNames = Map("akka" -> "org.apache.spark.rpc.akka.AkkaRpcEnvFactory",
40
"netty" -> "org.apache.spark.rpc.netty.NettyRpcEnvFactory")
41
- // Use "netty" by default so that Jenkins can run all tests using NettyRpcEnv.
42
- // Will change it back to "akka" before merging the new implementation.
43
val rpcEnvName = conf.get("spark.rpc", "netty")
44
val rpcEnvFactoryClassName = rpcEnvNames.getOrElse(rpcEnvName.toLowerCase, rpcEnvName)
45
Utils.classForName(rpcEnvFactoryClassName).newInstance().asInstanceOf[RpcEnvFactory]
0 commit comments