Skip to content

Commit

Permalink
reverting the changes to startJettyServer()
Browse files Browse the repository at this point in the history
  • Loading branch information
kanzhang committed Apr 5, 2014
1 parent 7a8084e commit e625a5f
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions core/src/main/scala/org/apache/spark/ui/JettyUtils.scala
Original file line number Diff line number Diff line change
Expand Up @@ -177,10 +177,7 @@ private[spark] object JettyUtils extends Logging {

@tailrec
def connect(currentPort: Int): (Server, Int) = {
val server = if ("0.0.0.0".equals(hostName))
new Server(currentPort)
else
new Server(new InetSocketAddress(hostName, currentPort))
val server = new Server(new InetSocketAddress(hostName, currentPort))
val pool = new QueuedThreadPool
pool.setDaemon(true)
server.setThreadPool(pool)
Expand Down

0 comments on commit e625a5f

Please sign in to comment.