Skip to content

Commit d7c97ca

Browse files
committed
Return the correctly bound port.
1 parent d14706f commit d7c97ca

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/ui/JettyUtils.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import scala.xml.Node
2929
import org.json4s.JValue
3030
import org.json4s.jackson.JsonMethods.{pretty, render}
3131

32-
import org.eclipse.jetty.server.Server
32+
import org.eclipse.jetty.server.{NetworkConnector, Server}
3333
import org.eclipse.jetty.server.handler.HandlerList
3434
import org.eclipse.jetty.servlet.{DefaultServlet, FilterHolder, ServletContextHandler, ServletHolder}
3535
import org.eclipse.jetty.util.thread.QueuedThreadPool
@@ -173,7 +173,7 @@ private[spark] object JettyUtils extends Logging {
173173
server.start()
174174
} match {
175175
case s: Success[_] =>
176-
(server, currentPort)
176+
(server, server.getConnectors.head.asInstanceOf[NetworkConnector].getLocalPort)
177177
case f: Failure[_] =>
178178
server.stop()
179179
logInfo("Failed to create UI at port, %s. Trying again.".format(currentPort))

0 commit comments

Comments
 (0)