diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-06-17 14:59:57 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-06-22 10:31:35 -0700 |
| commit | 7e6977b6c5f7c889b189285a7fa765db5ff2a285 (patch) | |
| tree | b717a8b96378174c97174c752d6d3221636507c9 | |
| parent | 950f83535a8393a131f97a1a64454a446c5ea31c (diff) | |
| download | spark-7e6977b6c5f7c889b189285a7fa765db5ff2a285.tar.gz spark-7e6977b6c5f7c889b189285a7fa765db5ff2a285.tar.bz2 spark-7e6977b6c5f7c889b189285a7fa765db5ff2a285.zip | |
Fix in storage status page
| -rw-r--r-- | core/src/main/scala/spark/storage/BlockManagerUI.scala | 22 |
1 files changed, 12 insertions, 10 deletions
diff --git a/core/src/main/scala/spark/storage/BlockManagerUI.scala b/core/src/main/scala/spark/storage/BlockManagerUI.scala index cea5c0907e..6ac4398de7 100644 --- a/core/src/main/scala/spark/storage/BlockManagerUI.scala +++ b/core/src/main/scala/spark/storage/BlockManagerUI.scala @@ -129,16 +129,18 @@ class BlockManagerUI(val actorSystem: ActorSystem, blockManagerMaster: ActorRef, </tr> </thead> <tbody> - {for(status <- storageStatusList) { - <tr> - <td>{status.blockManagerId.host + ":" + status.blockManagerId.port}</td> - <td> - {Utils.memoryBytesToString(status.memUsed(prefix))} - ({Utils.memoryBytesToString(status.memRemaining)} Total Available) - </td> - <td>{Utils.memoryBytesToString(status.diskUsed(prefix))}</td> - </tr> - }} + {filteredStorageStatusList.map { + status => + <tr> + <td>{status.blockManagerId.host + ":" + status.blockManagerId.port}</td> + <td> + {Utils.memoryBytesToString(status.memUsed(prefix))} + ({Utils.memoryBytesToString(status.memRemaining)} Total Available) + </td> + <td>{Utils.memoryBytesToString(status.diskUsed(prefix))}</td> + </tr> + } + } </tbody> </table> </div> |