blob: d6ff1c54cac306d6f9ff62b20b12e20114b45d7d (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
|
package spark.deploy
object ExecutorState
extends Enumeration("LAUNCHING", "LOADING", "RUNNING", "KILLED", "FAILED", "LOST") {
val LAUNCHING, LOADING, RUNNING, KILLED, FAILED, LOST = Value
type ExecutorState = Value
def isFinished(state: ExecutorState): Boolean = Seq(KILLED, FAILED, LOST).contains(state)
}
|
