Skip to content

Commit

Permalink
fix scala style
Browse files Browse the repository at this point in the history
  • Loading branch information
lianhuiwang committed Dec 1, 2015
1 parent 97dbd62 commit 16e175d
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -55,9 +55,9 @@ private[ui] class ExecutorsPage(
def render(request: HttpServletRequest): Seq[Node] = {
listener.synchronized {
val activeStorageStatusList = listener.activeStorageStatusList
val activeExecutorsTable = listingExecTable(activeStorageStatusList, true)
val activeExecutorsTable = listingExecTable(activeStorageStatusList, true)
val deadStorageStatusList = listener.deadStorageStatusList
val deadExecutorsTable = listingExecTable(deadStorageStatusList, false)
val deadExecutorsTable = listingExecTable(deadStorageStatusList, false)
val content =
<span>
<h4>ActiveExecutors({activeStorageStatusList.size})</h4> {activeExecutorsTable}
Expand All @@ -79,6 +79,7 @@ private[ui] class ExecutorsPage(
val logsExist = execInfo.filter(_.executorLogs.nonEmpty).nonEmpty
val isShowThreadDump = threadDumpEnabled && isActive

// scalastyle:off
<div class="row-fluid">
<div class="span12">
{
Expand Down Expand Up @@ -122,6 +123,7 @@ private[ui] class ExecutorsPage(
</table>
</div>
</div>
// scalastyle:on
}

/** Render an HTML row representing an executor */
Expand Down Expand Up @@ -189,7 +191,8 @@ private[ui] class ExecutorsPage(

private[spark] object ExecutorsPage {
/** Represent an executor's info as a map given a storage status index */
def getExecInfo(listener: ExecutorsListener, statusId: Int, isActive: Boolean): ExecutorSummary = {
def getExecInfo(listener: ExecutorsListener, statusId: Int, isActive: Boolean)
: ExecutorSummary = {
val status = if (isActive) {
listener.activeStorageStatusList(statusId)
} else {
Expand Down

0 comments on commit 16e175d

Please sign in to comment.