File tree Expand file tree Collapse file tree 1 file changed +18
-10
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +18
-10
lines changed Original file line number Diff line number Diff line change @@ -90,17 +90,25 @@ class SparkEnv (
90
90
private var driverTmpDirToDelete : Option [String ] = None
91
91
92
92
private [spark] def stop () {
93
+
94
+ if (isStopped) return
95
+
93
96
isStopped = true
94
- pythonWorkers.foreach { case (key, worker) => worker.stop() }
95
- Option (httpFileServer).foreach(_.stop())
96
- mapOutputTracker.stop()
97
- shuffleManager.stop()
98
- broadcastManager.stop()
99
- blockManager.stop()
100
- blockManager.master.stop()
101
- metricsSystem.stop()
102
- outputCommitCoordinator.stop()
103
- rpcEnv.shutdown()
97
+ try {
98
+ pythonWorkers.foreach { case (key, worker) => worker.stop()}
99
+ Option (httpFileServer).foreach(_.stop())
100
+ mapOutputTracker.stop()
101
+ shuffleManager.stop()
102
+ broadcastManager.stop()
103
+ blockManager.stop()
104
+ blockManager.master.stop()
105
+ metricsSystem.stop()
106
+ outputCommitCoordinator.stop()
107
+ rpcEnv.shutdown()
108
+ } catch {
109
+ case e : Exception =>
110
+ logInfo(" Exception while SparkEnv stop" , e)
111
+ }
104
112
105
113
// Unfortunately Akka's awaitTermination doesn't actually wait for the Netty server to shut
106
114
// 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