diff --git a/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala b/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala index 14a453699d3a1ff68e65957219048634f1ee8b48..b8856e6e001ab75a0c2bdc53d1f1beff4a93a10b 100644 --- a/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala +++ b/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala @@ -129,6 +129,6 @@ private[deploy] object DeployMessages { case object RequestWebUIPort - case class WebUIPortResponse(boundedPort: Int) {} + case class WebUIPortResponse(webUIBoundPort: Int) {} } diff --git a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala index 50d5900ecd4333959de6ae33786860feffb1e9dc..dd7dcae6194b8fddfdcafbef59f3c79a5965a5ec 100644 --- a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala +++ b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala @@ -389,9 +389,9 @@ private[spark] object Master { def startSystemAndActor(host: String, port: Int, webUiPort: Int): (ActorSystem, Int, Int) = { val (actorSystem, boundPort) = AkkaUtils.createActorSystem(systemName, host, port) val actor = actorSystem.actorOf(Props(new Master(host, boundPort, webUiPort)), name = actorName) - implicit val timeout = Timeout(1 seconds) - val respFuture = actor ? RequestWebUIPort + implicit val timeout = Timeout(5 seconds) + val respFuture = actor ? RequestWebUIPort // ask pattern val resp = Await.result(respFuture, timeout.duration).asInstanceOf[WebUIPortResponse] - (actorSystem, boundPort, resp.boundedPort) + (actorSystem, boundPort, resp.webUIBoundPort) } }