File tree Expand file tree Collapse file tree
core/src/main/scala/org/apache/spark/rpc/netty
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -41,9 +41,9 @@ private[netty] class Dispatcher(nettyEnv: NettyRpcEnv) extends Logging {
4141 val inbox = new Inbox (ref, endpoint)
4242 }
4343
44- private val endpoints : ConcurrentMap [String , EndpointData ] =
44+ private val endpoints : ConcurrentMap [String , EndpointData ] =
4545 new ConcurrentHashMap [String , EndpointData ]
46- private val endpointRefs : ConcurrentMap [RpcEndpoint , RpcEndpointRef ] =
46+ private val endpointRefs : ConcurrentMap [RpcEndpoint , RpcEndpointRef ] =
4747 new ConcurrentHashMap [RpcEndpoint , RpcEndpointRef ]
4848
4949 // Track the receivers whose inboxes may contain messages.
Original file line number Diff line number Diff line change @@ -80,7 +80,7 @@ trait Catalog {
8080}
8181
8282class SimpleCatalog (val conf : CatalystConf ) extends Catalog {
83- private [this ] val tables : ConcurrentMap [String , LogicalPlan ] =
83+ private [this ] val tables : ConcurrentMap [String , LogicalPlan ] =
8484 new ConcurrentHashMap [String , LogicalPlan ]
8585
8686 override def registerTable (tableIdent : TableIdentifier , plan : LogicalPlan ): Unit = {
You can’t perform that action at this time.
0 commit comments