Comments, imports and formatting (minor)

Author: andrewor14

core/src/main/scala/org/apache/spark/deploy/master/Master.scala

@@ -85,7 +85,6 @@ private[spark] class Master(
   val masterSource = new MasterSource(this)
 
   val webUi = new MasterWebUI(this, webUiPort)
-  webUi.start()
 
   val masterPublicAddress = {
     val envVar = System.getenv("SPARK_PUBLIC_DNS")
@@ -116,6 +115,7 @@ private[spark] class Master(
     logInfo("Starting Spark master at " + masterUrl)
     // Listen for remote client disconnection events, since they don't go through Akka's watch()
     context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
+    webUi.start()
     webUi.bind()
     masterWebUiUrl = "http://" + masterPublicAddress + ":" + webUi.boundPort
     context.system.scheduler.schedule(0 millis, WORKER_TIMEOUT millis, self, CheckForWorkerTimeOut)

core/src/main/scala/org/apache/spark/deploy/master/ui/MasterWebUI.scala

@@ -35,6 +35,7 @@ class MasterWebUI(val master: Master, requestedPort: Int)
   val masterActorRef = master.self
   val timeout = AkkaUtils.askTimeout(master.conf)
 
+  /** Initialize all components of the server. Must be called before bind(). */
   def start() {
     attachPage(new ApplicationPage(this))
     attachPage(new IndexPage(this))

core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala

@@ -122,10 +122,10 @@ private[spark] class Worker(
       host, port, cores, Utils.megabytesToString(memory)))
     logInfo("Spark home: " + sparkHome)
     createWorkDir()
+    context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
     webUi = new WorkerWebUI(this, workDir, Some(webUiPort))
     webUi.start()
     webUi.bind()
-    context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
     registerWithMaster()
 
     metricsSystem.registerSource(workerSource)

core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerWebUI.scala

@@ -38,6 +38,7 @@ class WorkerWebUI(val worker: Worker, val workDir: File, requestedPort: Option[I
     worker.conf.get("worker.ui.port",  WorkerWebUI.DEFAULT_PORT).toInt)
   val timeout = AkkaUtils.askTimeout(worker.conf)
 
+  /** Initialize all components of the server. Must be called before bind(). */
   def start() {
     val logPage = new LogPage(this)
     attachPage(logPage)

core/src/main/scala/org/apache/spark/ui/WebUI.scala

@@ -19,15 +19,16 @@ package org.apache.spark.ui
 
 import javax.servlet.http.HttpServletRequest
 
+import scala.collection.mutable.ArrayBuffer
+import scala.xml.Node
+
 import org.eclipse.jetty.servlet.ServletContextHandler
+import org.json4s.JsonAST.{JNothing, JValue}
 
 import org.apache.spark.SecurityManager
+import org.apache.spark.scheduler.SparkListener
 import org.apache.spark.ui.JettyUtils._
 import org.apache.spark.util.Utils
-import scala.collection.mutable.ArrayBuffer
-import org.apache.spark.scheduler.SparkListener
-import scala.xml.Node
-import org.json4s.JsonAST.{JNothing, JValue}
 
 /**
  * The top level component of the UI hierarchy that contains the server.
@@ -70,6 +71,9 @@ private[spark] abstract class WebUI(securityManager: SecurityManager, basePath:
   /** Return a list of handlers attached to this UI. */
   def getHandlers = handlers.toSeq
 
+  /** Initialize all components of the server. Must be called before bind(). */
+  def start()
+
   /**
    * Bind to the HTTP server behind this web interface.
    * Overridden implementation should set serverInfo.
@@ -101,6 +105,7 @@ private[spark] abstract class UITab(val prefix: String) {
     pages += page
   }
 
+  /** Initialize listener and attach pages. */
   def start()
 }
 

core/src/main/scala/org/apache/spark/ui/env/EnvironmentTab.scala

@@ -29,7 +29,7 @@ private[ui] class EnvironmentTab(parent: SparkUI) extends UITab("environment") {
     attachPage(new IndexPage(this))
   }
 
-  def environmentListener = {
+  def environmentListener: EnvironmentListener = {
     assert(listener.isDefined, "EnvironmentTab has not started yet!")
     listener.get.asInstanceOf[EnvironmentListener]
   }

core/src/main/scala/org/apache/spark/ui/exec/ExecutorsTab.scala

@@ -33,7 +33,7 @@ private[ui] class ExecutorsTab(parent: SparkUI) extends UITab("executors") {
     attachPage(new IndexPage(this))
   }
 
-  def executorsListener = {
+  def executorsListener: ExecutorsListener = {
     assert(listener.isDefined, "ExecutorsTab has not started yet!")
     listener.get.asInstanceOf[ExecutorsListener]
   }

core/src/main/scala/org/apache/spark/ui/exec/IndexPage.scala

@@ -50,11 +50,11 @@ private[ui] class IndexPage(parent: ExecutorsTab) extends UIPage("") {
           </ul>
         </div>
       </div>
-        <div class = "row">
-          <div class="span12">
-            {execTable}
-          </div>
-        </div>;
+      <div class = "row">
+        <div class="span12">
+          {execTable}
+        </div>
+      </div>;
 
     UIUtils.headerSparkPage(
       content, basePath, appName, "Executors (" + execInfo.size + ")", Executors)

core/src/main/scala/org/apache/spark/ui/jobs/IndexPage.scala

@@ -22,8 +22,8 @@ import javax.servlet.http.HttpServletRequest
 import scala.xml.{Node, NodeSeq}
 
 import org.apache.spark.scheduler.Schedulable
-import org.apache.spark.ui.Page._
 import org.apache.spark.ui.{UIPage, UIUtils}
+import org.apache.spark.ui.Page.Stages
 
 /** Page showing list of all ongoing and recently finished stages and pools */
 private[ui] class IndexPage(parent: JobProgressTab) extends UIPage("") {

core/src/main/scala/org/apache/spark/ui/jobs/JobProgressTab.scala

@@ -36,7 +36,7 @@ private[ui] class JobProgressTab(parent: SparkUI) extends UITab("stages") {
     attachPage(new PoolPage(this))
   }
 
-  def jobProgressListener = {
+  def jobProgressListener: JobProgressListener = {
     assert(listener.isDefined, "JobProgressTab has not started yet!")
     listener.get.asInstanceOf[JobProgressListener]
   }