diff options
| author | Kay Ousterhout <kayo@yahoo-inc.com> | 2013-08-13 14:27:40 -0700 |
|---|---|---|
| committer | Kay Ousterhout <kayo@yahoo-inc.com> | 2013-08-13 14:27:40 -0700 |
| commit | 1beb843a6f94644387dba36e92f4850e57de9194 (patch) | |
| tree | 92139628a4b76dbdf3f1197663dd3bc79fb9cd5c /core | |
| parent | c92dd627ca4c0ce580b8be54010827440da77505 (diff) | |
| download | spark-1beb843a6f94644387dba36e92f4850e57de9194.tar.gz spark-1beb843a6f94644387dba36e92f4850e57de9194.tar.bz2 spark-1beb843a6f94644387dba36e92f4850e57de9194.zip | |
Reuse the set of failed states rather than creating a new object each time
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/TaskState.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/TaskState.scala b/core/src/main/scala/spark/TaskState.scala index 0955a91c6f..bf75753056 100644 --- a/core/src/main/scala/spark/TaskState.scala +++ b/core/src/main/scala/spark/TaskState.scala @@ -24,9 +24,11 @@ private[spark] object TaskState val LAUNCHING, RUNNING, FINISHED, FAILED, KILLED, LOST = Value + val FINISHED_STATES = Set(FINISHED, FAILED, KILLED, LOST) + type TaskState = Value - def isFinished(state: TaskState) = Seq(FINISHED, FAILED, KILLED, LOST).contains(state) + def isFinished(state: TaskState) = FINISHED_STATES.contains(state) def toMesos(state: TaskState): MesosTaskState = state match { case LAUNCHING => MesosTaskState.TASK_STARTING |