Skip to content

Commit 57cade1

Browse files
author
Michael Allman
committed
Stop the event logger after the event listeners and before the DAG
scheduler, take 3. This was my original intention, bungled twice :/
1 parent 6c32f77 commit 57cade1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

core/src/main/scala/org/apache/spark/SparkContext.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1681,15 +1681,15 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
16811681
Utils.tryLogNonFatalError {
16821682
_executorAllocationManager.foreach(_.stop())
16831683
}
1684-
Utils.tryLogNonFatalError {
1685-
_eventLogger.foreach(_.stop())
1686-
}
16871684
if (_listenerBusStarted) {
16881685
Utils.tryLogNonFatalError {
16891686
listenerBus.stop()
16901687
_listenerBusStarted = false
16911688
}
16921689
}
1690+
Utils.tryLogNonFatalError {
1691+
_eventLogger.foreach(_.stop())
1692+
}
16931693
if (_dagScheduler != null) {
16941694
Utils.tryLogNonFatalError {
16951695
_dagScheduler.stop()

0 commit comments

Comments
 (0)