You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ka...@apache.org on 2014/11/01 01:23:01 UTC
git commit: SPARK-4175. Exception on stage page
Repository: spark
Updated Branches:
refs/heads/master 087e31a7a -> 23f73f525
SPARK-4175. Exception on stage page
Author: Sandy Ryza <sa...@cloudera.com>
Closes #3043 from sryza/sandy-spark-4175 and squashes the following commits:
e327340 [Sandy Ryza] SPARK-4175. Exception on stage page
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/23f73f52
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/23f73f52
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/23f73f52
Branch: refs/heads/master
Commit: 23f73f525ce3d2b4a614e60f4f9170c860ab93da
Parents: 087e31a
Author: Sandy Ryza <sa...@cloudera.com>
Authored: Fri Oct 31 17:22:52 2014 -0700
Committer: Kay Ousterhout <ka...@gmail.com>
Committed: Fri Oct 31 17:22:52 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/23f73f52/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
----------------------------------------------------------------------
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
index bf45272..7cc03b7 100644
--- a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
+++ b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
@@ -312,7 +312,7 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") {
else metrics.map(_.executorRunTime).getOrElse(1L)
val formatDuration = if (info.status == "RUNNING") UIUtils.formatDuration(duration)
else metrics.map(m => UIUtils.formatDuration(m.executorRunTime)).getOrElse("")
- val schedulerDelay = getSchedulerDelay(info, metrics.get)
+ val schedulerDelay = metrics.map(getSchedulerDelay(info, _)).getOrElse(0L)
val gcTime = metrics.map(_.jvmGCTime).getOrElse(0L)
val serializationTime = metrics.map(_.resultSerializationTime).getOrElse(0L)
val gettingResultTime = info.gettingResultTime
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org