File tree Expand file tree Collapse file tree 1 file changed +12
-16
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +12
-16
lines changed Original file line number Diff line number Diff line change @@ -95,22 +95,18 @@ class SparkEnv (
9595
9696 if (! isStopped) {
9797 isStopped = true
98- try {
99- pythonWorkers.foreach { case (key, worker) => worker.stop()}
100- Option (httpFileServer).foreach(_.stop())
101- mapOutputTracker.stop()
102- shuffleManager.stop()
103- broadcastManager.stop()
104- blockManager.stop()
105- blockManager.master.stop()
106- metricsSystem.stop()
107- outputCommitCoordinator.stop()
108- rpcEnv.shutdown()
109- } catch {
110- case NonFatal (e) =>
111- logInfo(" Exception while SparkEnv stop" , e)
112- throw e;
113- }
98+
99+ pythonWorkers.foreach { case (key, worker) => worker.stop()}
100+ Option (httpFileServer).foreach(_.stop())
101+ mapOutputTracker.stop()
102+ shuffleManager.stop()
103+ broadcastManager.stop()
104+ blockManager.stop()
105+ blockManager.master.stop()
106+ metricsSystem.stop()
107+ outputCommitCoordinator.stop()
108+ rpcEnv.shutdown()
109+
114110
115111 // Unfortunately Akka's awaitTermination doesn't actually wait for the Netty server to shut
116112 // down, but let's call it anyway in case it gets fixed in a later release
You can’t perform that action at this time.
0 commit comments