File tree Expand file tree Collapse file tree 1 file changed +10
-4
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ class SparkEnv (
7979
8080 private [spark] def stop () {
8181 pythonWorkers.foreach { case (key, worker) => worker.stop() }
82- httpFileServer. stop()
82+ Option ( httpFileServer).foreach(_. stop() )
8383 mapOutputTracker.stop()
8484 shuffleManager.stop()
8585 broadcastManager.stop()
@@ -228,9 +228,15 @@ object SparkEnv extends Logging {
228228
229229 val cacheManager = new CacheManager (blockManager)
230230
231- val httpFileServer = new HttpFileServer (securityManager)
232- httpFileServer.initialize()
233- conf.set(" spark.fileserver.uri" , httpFileServer.serverUri)
231+ val httpFileServer =
232+ if (isDriver) {
233+ val server = new HttpFileServer (securityManager)
234+ server.initialize()
235+ conf.set(" spark.fileserver.uri" , server.serverUri)
236+ server
237+ } else {
238+ null
239+ }
234240
235241 val metricsSystem = if (isDriver) {
236242 MetricsSystem .createMetricsSystem(" driver" , conf, securityManager)
You can’t perform that action at this time.
0 commit comments