File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
main/scala/org/apache/spark/ui/exec
test/scala/org/apache/spark/ui/storage Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ private[ui] class ExecutorsPage(parent: ExecutorsTab) extends WebUIPage("") {
5151 val storageStatusList = listener.storageStatusList
5252 val maxMem = storageStatusList.map(_.maxMem).fold(0L )(_ + _)
5353 val memUsed = storageStatusList.map(_.memUsed).fold(0L )(_ + _)
54- val diskSpaceUsed = storageStatusList.map(_.diskUsed).reduceOption( _ + _).getOrElse( 0L )
54+ val diskUsed = storageStatusList.map(_.diskUsed).fold( 0L )( _ + _)
5555 val execInfo = for (statusId <- 0 until storageStatusList.size) yield getExecInfo(statusId)
5656 val execInfoSorted = execInfo.sortBy(_.id)
5757
@@ -80,7 +80,7 @@ private[ui] class ExecutorsPage(parent: ExecutorsTab) extends WebUIPage("") {
8080 </th >
8181 </thead >
8282 <tbody >
83- {execInfoSorted.map(execRow(_) )}
83+ {execInfoSorted.map(execRow)}
8484 </tbody >
8585 </table >
8686
@@ -91,7 +91,7 @@ private[ui] class ExecutorsPage(parent: ExecutorsTab) extends WebUIPage("") {
9191 <li ><strong >Memory :</ strong>
9292 {Utils .bytesToString(memUsed)} Used
9393 ({Utils .bytesToString(maxMem)} Total ) </li >
94- <li ><strong >Disk :</ strong> {Utils .bytesToString(diskSpaceUsed )} Used </li >
94+ <li ><strong >Disk :</ strong> {Utils .bytesToString(diskUsed )} Used </li >
9595 </ul >
9696 </div >
9797 </div >
Original file line number Diff line number Diff line change @@ -162,4 +162,4 @@ class StorageTabSuite extends FunSuite with BeforeAndAfter {
162162 assert(storageListener._rddInfoMap(2 ).numCachedPartitions === 0 )
163163 }
164164
165- }
165+ }
You can’t perform that action at this time.
0 commit comments