Fixed defaulting to job.name in lastStageNameAndDescription

apache · Jan 20, 2018 · c733ac9 · c733ac9
1 parent f19d3a1
commit c733ac9
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
@@ -1001,11 +1001,8 @@ private object ApiHelper {
   }
 
   def lastStageNameAndDescription(store: AppStatusStore, job: JobData): (String, String) = {
-    store.asOption(store.lastStageAttempt(job.stageIds.max)) match {
-      case Some(lastStageAttempt) =>
-        (lastStageAttempt.name, lastStageAttempt.description.getOrElse(job.name))
-      case None => ("", "")
-    }
+    val stage = store.asOption(store.lastStageAttempt(job.stageIds.max))
+    (stage.map(_.name).getOrElse(""), stage.flatMap(_.description).getOrElse(job.name))
   }
 
 }