Skip to content
Snippets Groups Projects
Commit a807fcbe authored by Rohit Agarwal's avatar Rohit Agarwal Committed by Andrew Or
Browse files

[SPARK-9806] [WEB UI] Don't share ReplayListenerBus between multiple applications

Author: Rohit Agarwal <rohita@qubole.com>

Closes #8088 from mindprince/SPARK-9806.
parent b85f9a24
No related branches found
No related tags found
No related merge requests found
......@@ -272,9 +272,9 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock)
* Replay the log files in the list and merge the list of old applications with new ones
*/
private def mergeApplicationListing(logs: Seq[FileStatus]): Unit = {
val bus = new ReplayListenerBus()
val newAttempts = logs.flatMap { fileStatus =>
try {
val bus = new ReplayListenerBus()
val res = replay(fileStatus, bus)
res match {
case Some(r) => logDebug(s"Application log ${r.logPath} loaded successfully.")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment