From aca0ba64887149213367aa7b1ac0e4ce2afa90ce Mon Sep 17 00:00:00 2001
From: zsxwing <zsxwing@gmail.com>
Date: Thu, 7 May 2015 11:58:53 -0700
Subject: [PATCH] Fix the code style

---
 .../org/apache/spark/streaming/ui/BatchPage.scala   | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala b/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
index 36dd6e552ad28..831f60e870f74 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
@@ -200,14 +200,13 @@ private[ui] class BatchPage(parent: StreamingTab) extends WebUIPage("batch") {
   private def generateOutputOpDescription(sparkJobs: Seq[SparkJobIdWithUIData]): Seq[Node] = {
     val lastStageInfo =
       sparkJobs.flatMap(_.jobUIData).headOption. // Get the first JobUIData
-        // Get the latest Stage info
-        flatMap { sparkJob =>
-        if (sparkJob.stageIds.isEmpty) {
-          None
-        } else {
-          sparkListener.stageIdToInfo.get(sparkJob.stageIds.max)
+        flatMap { sparkJob => // For the first job, get the latest Stage info
+          if (sparkJob.stageIds.isEmpty) {
+            None
+          } else {
+            sparkListener.stageIdToInfo.get(sparkJob.stageIds.max)
+          }
         }
-      }
     val lastStageData = lastStageInfo.flatMap { s =>
       sparkListener.stageIdToData.get((s.stageId, s.attemptId))
     }