You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2013/11/20 01:11:43 UTC
[2/4] git commit: rename "a" to "statusId"
rename "a" to "statusId"
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/ecfbaf24
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/ecfbaf24
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/ecfbaf24
Branch: refs/heads/master
Commit: ecfbaf24426948a9c09225190e71bc1148a9944b
Parents: b60839e
Author: BlackNiuza <ze...@gmail.com>
Authored: Mon Nov 18 09:51:40 2013 +0800
Committer: shiyun.wxm <sh...@taobao.com>
Committed: Mon Nov 18 09:51:40 2013 +0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/ecfbaf24/core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala b/core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala
index ba198b2..26245a6 100644
--- a/core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala
+++ b/core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala
@@ -76,7 +76,7 @@ private[spark] class ExecutorsUI(val sc: SparkContext) {
</tr>
}
- val execInfo = for (b <- 0 until storageStatusList.size) yield getExecInfo(b)
+ val execInfo = for (statusId <- 0 until storageStatusList.size) yield getExecInfo(statusId)
val execTable = UIUtils.listingTable(execHead, execRow, execInfo)
val content =
@@ -99,8 +99,8 @@ private[spark] class ExecutorsUI(val sc: SparkContext) {
UIUtils.headerSparkPage(content, sc, "Executors (" + execInfo.size + ")", Executors)
}
- def getExecInfo(a: Int): Seq[String] = {
- val status = sc.getExecutorStorageStatus(a)
+ def getExecInfo(statusId: Int): Seq[String] = {
+ val status = sc.getExecutorStorageStatus(statusId)
val execId = status.blockManagerId.executorId
val hostPort = status.blockManagerId.hostPort
val rddBlocks = status.blocks.size.toString