Fix for SparkContext stop behavior

tresata-opensource · Jun 30, 2015 · 446b0a4 · 446b0a4
1 parent 2ce5760
commit 446b0a4
Showing 1 changed file with 12 additions and 16 deletions.
diff --git a/core/src/main/scala/org/apache/spark/SparkEnv.scala b/core/src/main/scala/org/apache/spark/SparkEnv.scala
@@ -95,22 +95,18 @@ class SparkEnv (
 
     if (!isStopped) {
       isStopped = true
-      try {
-        pythonWorkers.foreach { case (key, worker) => worker.stop()}
-        Option(httpFileServer).foreach(_.stop())
-        mapOutputTracker.stop()
-        shuffleManager.stop()
-        broadcastManager.stop()
-        blockManager.stop()
-        blockManager.master.stop()
-        metricsSystem.stop()
-        outputCommitCoordinator.stop()
-        rpcEnv.shutdown()
-      } catch {
-        case NonFatal(e) =>
-          logInfo("Exception while SparkEnv stop", e)
-          throw e;
-      }
+
+      pythonWorkers.foreach { case (key, worker) => worker.stop()}
+      Option(httpFileServer).foreach(_.stop())
+      mapOutputTracker.stop()
+      shuffleManager.stop()
+      broadcastManager.stop()
+      blockManager.stop()
+      blockManager.master.stop()
+      metricsSystem.stop()
+      outputCommitCoordinator.stop()
+      rpcEnv.shutdown()
+
 
       // Unfortunately Akka's awaitTermination doesn't actually wait for the Netty server to shut
       // down, but let's call it anyway in case it gets fixed in a later release