Skip to content

Commit f644b55

Browse files
committed
Use more specific service name
1 parent 4e98236 commit f644b55

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

core/src/main/scala/org/apache/spark/SparkEnv.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -146,9 +146,9 @@ object SparkEnv extends Logging {
146146
}
147147

148148
val securityManager = new SecurityManager(conf)
149-
150-
val (actorSystem, boundPort) = AkkaUtils.createActorSystem("spark", hostname, port, conf = conf,
151-
securityManager = securityManager)
149+
val actorSystemName = if (isDriver) "driver actor" else "executor actor"
150+
val (actorSystem, boundPort) = AkkaUtils.createActorSystem(
151+
actorSystemName, hostname, port, conf, securityManager)
152152

153153
// Figure out which port Akka actually bound to in case the original port is 0 or occupied.
154154
// This is so that we tell the executors the correct port to connect to.

0 commit comments

Comments
 (0)