Skip to content
Snippets Groups Projects
Commit 3f918b33 authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Merge pull request #672 from holdenk/master

s/ActorSystemImpl/ExtendedActorSystem/ as ActorSystemImpl results in a warning
parents 2a36e544 0f06d621
No related branches found
No related tags found
No related merge requests found
package spark.util
import akka.actor.{ActorRef, Props, ActorSystemImpl, ActorSystem}
import akka.actor.{ActorRef, Props, ExtendedActorSystem, ActorSystem}
import com.typesafe.config.ConfigFactory
import akka.util.duration._
import akka.pattern.ask
......@@ -56,7 +56,7 @@ private[spark] object AkkaUtils {
// Figure out the port number we bound to, in case port was passed as 0. This is a bit of a
// hack because Akka doesn't let you figure out the port through the public API yet.
val provider = actorSystem.asInstanceOf[ActorSystemImpl].provider
val provider = actorSystem.asInstanceOf[ExtendedActorSystem].provider
val boundPort = provider.asInstanceOf[RemoteActorRefProvider].transport.address.port.get
return (actorSystem, boundPort)
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment