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

Merge pull request #399 from NFLabs/master

Fix for hanging spark.HttpFileServer on the kind of virtual network
parents 49c78446 7e9ee2e8
No related branches found
No related tags found
No related merge requests found
...@@ -4,6 +4,7 @@ import java.io.File ...@@ -4,6 +4,7 @@ import java.io.File
import java.net.InetAddress import java.net.InetAddress
import org.eclipse.jetty.server.Server import org.eclipse.jetty.server.Server
import org.eclipse.jetty.server.bio.SocketConnector
import org.eclipse.jetty.server.handler.DefaultHandler import org.eclipse.jetty.server.handler.DefaultHandler
import org.eclipse.jetty.server.handler.HandlerList import org.eclipse.jetty.server.handler.HandlerList
import org.eclipse.jetty.server.handler.ResourceHandler import org.eclipse.jetty.server.handler.ResourceHandler
...@@ -27,7 +28,13 @@ private[spark] class HttpServer(resourceBase: File) extends Logging { ...@@ -27,7 +28,13 @@ private[spark] class HttpServer(resourceBase: File) extends Logging {
if (server != null) { if (server != null) {
throw new ServerStateException("Server is already started") throw new ServerStateException("Server is already started")
} else { } else {
server = new Server(0) server = new Server()
val connector = new SocketConnector
connector.setMaxIdleTime(60*1000)
connector.setSoLingerTime(-1)
connector.setPort(0)
server.addConnector(connector)
val threadPool = new QueuedThreadPool val threadPool = new QueuedThreadPool
threadPool.setDaemon(true) threadPool.setDaemon(true)
server.setThreadPool(threadPool) server.setThreadPool(threadPool)
......
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