Skip to content

Commit

Permalink
Fix merge.
Browse files Browse the repository at this point in the history
  • Loading branch information
Marcelo Vanzin committed Apr 3, 2015
1 parent 3979aad commit c671c46
Showing 1 changed file with 0 additions and 15 deletions.
15 changes: 0 additions & 15 deletions core/src/main/scala/org/apache/spark/SparkContext.scala
Original file line number Diff line number Diff line change
Expand Up @@ -1472,7 +1472,6 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
if (!stopped) {
stopped = true
postApplicationEnd()
<<<<<<< HEAD
_ui.foreach(_.stop())
if (env != null) {
env.metricsSystem.report()
Expand All @@ -1496,20 +1495,6 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
}
_progressBar.foreach(_.stop())
_taskScheduler = null
=======
ui.foreach(_.stop())
env.metricsSystem.report()
metadataCleaner.cancel()
cleaner.foreach(_.stop())
executorAllocationManager.foreach(_.stop())
dagScheduler.stop()
dagScheduler = null
listenerBus.stop()
eventLogger.foreach(_.stop())
env.actorSystem.stop(heartbeatReceiver)
progressBar.foreach(_.stop())
taskScheduler = null
>>>>>>> master
// TODO: Cache.stop()?
if (_env != null) {
_env.stop()
Expand Down

0 comments on commit c671c46

Please sign in to comment.