diff options
| author | BlackNiuza <zeming89@gmail.com> | 2013-11-18 09:51:40 +0800 |
|---|---|---|
| committer | shiyun.wxm <shiyun.wxm@taobao.com> | 2013-11-18 09:51:40 +0800 |
| commit | ecfbaf24426948a9c09225190e71bc1148a9944b (patch) | |
| tree | ef5bf40c7a63cd8b6cbe738c7c0af28f961a7ce5 | |
| parent | b60839e56a335d0e30578d1c4cad5b0319d565df (diff) | |
| download | spark-ecfbaf24426948a9c09225190e71bc1148a9944b.tar.gz spark-ecfbaf24426948a9c09225190e71bc1148a9944b.tar.bz2 spark-ecfbaf24426948a9c09225190e71bc1148a9944b.zip | |
rename "a" to "statusId"
| -rw-r--r-- | core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala | 6 |
1 files changed, 3 insertions, 3 deletions
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 ba198b211d..26245a6540 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 |