Skip to content
Snippets Groups Projects
Commit 7e9ee2e8 authored by Leemoonsoo's avatar Leemoonsoo
Browse files

Fix for hanging spark.HttpFileServer with kind of virtual network

parent 7d3e359f
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