File tree Expand file tree Collapse file tree 2 files changed +3
-7
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -1182,11 +1182,7 @@ class SparkContext(config: SparkConf) extends Logging {
11821182 listenerBus.post(SparkListenerApplicationStart (appName, startTime, sparkUser))
11831183 }
11841184
1185- /**
1186- * Post the application end event to all listeners immediately, rather than adding it
1187- * to the event queue for it to be asynchronously processed eventually. Otherwise, a race
1188- * condition exists in which the listeners may stop before this event has been propagated.
1189- */
1185+ /** Post the application end event */
11901186 private def postApplicationEnd () {
11911187 listenerBus.post(SparkListenerApplicationEnd (System .currentTimeMillis))
11921188 }
Original file line number Diff line number Diff line change @@ -32,8 +32,8 @@ import org.apache.spark.util.JsonProtocol
3232/**
3333 * A SparkListenerBus that replays logged events from persisted storage.
3434 *
35- * This class expects files to be appropriately prefixed as specified in EventLoggingListener.
36- * There exists a one-to-one mapping between ReplayListenerBus and event logging applications .
35+ * This assumes the given paths are valid log files, where each line can be deserialized into
36+ * exactly one SparkListenerEvent .
3737 */
3838private [spark] class ReplayListenerBus (
3939 logPaths : Seq [Path ],
You can’t perform that action at this time.
0 commit comments