Skip to content

Commit a24eab2

Browse files
author
Marcelo Vanzin
committed
Feedback.
1 parent 112ae8f commit a24eab2

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock)
140140
override def getAppUI(appId: String, attemptId: Option[String]): Option[SparkUI] = {
141141
try {
142142
applications.get(appId).flatMap { appInfo =>
143-
appInfo.attempts.find(_.attemptId == attemptId).map { attempt =>
143+
appInfo.attempts.find(_.attemptId == attemptId).flatMap { attempt =>
144144
val replayBus = new ReplayListenerBus()
145145
val ui = {
146146
val conf = this.conf.clone()
@@ -162,7 +162,7 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock)
162162
ui.getSecurityManager.setViewAcls(attempt.sparkUser,
163163
appListener.viewAcls.getOrElse(""))
164164
ui
165-
}.orNull
165+
}
166166
}
167167
}
168168
} catch {

0 commit comments

Comments
 (0)