aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2013-06-28 13:25:26 -0700
committerPatrick Wendell <pwendell@gmail.com>2013-06-28 13:25:26 -0700
commit249f0e54ba6c358b3d786b1ba42e5d2ea22ed9db (patch)
treed4745614ba48d2c3d0e3f4f6a6eaf8eba1c18167 /core
parentc537e869f3a12e75fac862cc6fdcf27a3e1e01b4 (diff)
downloadspark-249f0e54ba6c358b3d786b1ba42e5d2ea22ed9db.tar.gz
spark-249f0e54ba6c358b3d786b1ba42e5d2ea22ed9db.tar.bz2
spark-249f0e54ba6c358b3d786b1ba42e5d2ea22ed9db.zip
Minor changes from Matei's review
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/ui/JettyUtils.scala2
-rw-r--r--core/src/main/scala/spark/ui/jobs/IndexPage.scala21
-rw-r--r--core/src/main/scala/spark/ui/jobs/JobProgressUI.scala2
3 files changed, 11 insertions, 14 deletions
diff --git a/core/src/main/scala/spark/ui/JettyUtils.scala b/core/src/main/scala/spark/ui/JettyUtils.scala
index 8cc50bc5b0..9e4b884379 100644
--- a/core/src/main/scala/spark/ui/JettyUtils.scala
+++ b/core/src/main/scala/spark/ui/JettyUtils.scala
@@ -160,8 +160,8 @@ private[spark] object UIUtils {
{jobs}
</ul>
<ul id="infolist">
- <li>Master: <strong>{sc.master}</strong></li>
<li>Application: <strong>{sc.appName}</strong></li>
+ <li>Master: <strong>{sc.master}</strong></li>
<li>Executors: <strong>{sc.getExecutorStorageStatus.size}</strong></li>
</ul>
</div>
diff --git a/core/src/main/scala/spark/ui/jobs/IndexPage.scala b/core/src/main/scala/spark/ui/jobs/IndexPage.scala
index f5ed08744c..27c017d7ee 100644
--- a/core/src/main/scala/spark/ui/jobs/IndexPage.scala
+++ b/core/src/main/scala/spark/ui/jobs/IndexPage.scala
@@ -1,7 +1,5 @@
package spark.ui.jobs
-import akka.util.Duration
-
import java.util.Date
import javax.servlet.http.HttpServletRequest
@@ -26,9 +24,9 @@ private[spark] class IndexPage(parent: JobProgressUI) {
val completedStages = listener.completedStages.reverse.toSeq
val failedStages = listener.failedStages.reverse.toSeq
- val activeStageTable: NodeSeq = listingTable(stageHeaders, stageRow(), activeStages)
- val completedStageTable = listingTable(stageHeaders, stageRow(), completedStages)
- val failedStageTable: NodeSeq = listingTable(stageHeaders, stageRow(false), failedStages)
+ val activeStageTable: NodeSeq = listingTable(stageHeaders, stageRow, activeStages)
+ val completedStageTable = listingTable(stageHeaders, stageRow, completedStages)
+ val failedStageTable: NodeSeq = listingTable(stageHeaders, stageRow, failedStages)
val content = <h2>Active Stages</h2> ++ activeStageTable ++
<h2>Completed Stages</h2> ++ completedStageTable ++
@@ -44,7 +42,7 @@ private[spark] class IndexPage(parent: JobProgressUI) {
}
}
- def makeSlider(completed: Int, total: Int): Seq[Node] = {
+ def makeProgressBar(completed: Int, total: Int): Seq[Node] = {
val width=130
val height=15
val completeWidth = (completed.toDouble / total) * width
@@ -53,12 +51,12 @@ private[spark] class IndexPage(parent: JobProgressUI) {
<rect width={width.toString} height={height.toString}
fill="white" stroke="black" stroke-width="1" />
<rect width={completeWidth.toString} height={height.toString}
- fill="rgb(206,206,247)" stroke="black" stroke-width="1" />
+ fill="rgb(51,51,51)" stroke="black" stroke-width="1" />
</svg>
}
- def stageRow(showLink: Boolean = true)(s: Stage): Seq[Node] = {
+ def stageRow(s: Stage): Seq[Node] = {
val submissionTime = s.submissionTime match {
case Some(t) => dateFmt.format(new Date(t))
case None => "Unknown"
@@ -74,13 +72,12 @@ private[spark] class IndexPage(parent: JobProgressUI) {
val totalTasks = s.numPartitions
<tr>
- {if (showLink) {<td><a href={"/stages/stage?id=%s".format(s.id)}>{s.id}</a></td>}
- else {<td>{s.id}</td>}}
- <td>{s.origin}</td>
+ <td>{s.id}</td>
+ <td><a href={"/stages/stage?id=%s".format(s.id)}>{s.origin}</a></td>
<td>{submissionTime}</td>
<td>{getElapsedTime(s.submissionTime,
s.completionTime.getOrElse(System.currentTimeMillis()))}</td>
- <td>{makeSlider(completedTasks, totalTasks)}</td>
+ <td>{makeProgressBar(completedTasks, totalTasks)}</td>
<td>{completedTasks} / {totalTasks}
{listener.stageToTasksFailed.getOrElse(s.id, 0) match {
case f if f > 0 => "(%s failed)".format(f)
diff --git a/core/src/main/scala/spark/ui/jobs/JobProgressUI.scala b/core/src/main/scala/spark/ui/jobs/JobProgressUI.scala
index a18bf0f81e..f584d1e187 100644
--- a/core/src/main/scala/spark/ui/jobs/JobProgressUI.scala
+++ b/core/src/main/scala/spark/ui/jobs/JobProgressUI.scala
@@ -23,7 +23,7 @@ import spark.Utils
private[spark] class JobProgressUI(val sc: SparkContext) {
private var _listener: Option[JobProgressListener] = None
def listener = _listener.get
- val dateFmt = new SimpleDateFormat("EEE, MMM d yyyy HH:mm:ss")
+ val dateFmt = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss")
private val indexPage = new IndexPage(this)
private val stagePage = new StagePage(this)