From eda05fa43953f601d14853f3416e99e012a1bbba Mon Sep 17 00:00:00 2001 From: "shiyun.wxm" <shiyun.wxm@taobao.com> Date: Mon, 18 Nov 2013 13:31:14 +0800 Subject: [PATCH] use HashSet.empty[Long] instead of Seq[Long] --- core/src/main/scala/org/apache/spark/ui/exec/ExecutorsUI.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 26245a6540..e596690bc3 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 @@ -107,7 +107,7 @@ private[spark] class ExecutorsUI(val sc: SparkContext) { val memUsed = status.memUsed().toString val maxMem = status.maxMem.toString val diskUsed = status.diskUsed().toString - val activeTasks = listener.executorToTasksActive.getOrElse(execId, Seq[Long]()).size + val activeTasks = listener.executorToTasksActive.getOrElse(execId, HashSet.empty[Long]).size val failedTasks = listener.executorToTasksFailed.getOrElse(execId, 0) val completedTasks = listener.executorToTasksComplete.getOrElse(execId, 0) val totalTasks = activeTasks + failedTasks + completedTasks -- GitLab