We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c89bb6e commit fbb65b8Copy full SHA for fbb65b8
core/src/main/scala/org/apache/spark/deploy/master/ApplicationInfo.scala
@@ -24,7 +24,7 @@ import scala.collection.mutable.ArrayBuffer
24
25
import akka.actor.ActorRef
26
27
-import org.apache.spark.deploy.{ApplicationDescription, ExecutorState}
+import org.apache.spark.deploy.ApplicationDescription
28
29
private[spark] class ApplicationInfo(
30
val startTime: Long,
@@ -83,10 +83,6 @@ private[spark] class ApplicationInfo(
83
}
84
85
86
- def exitedExecutors: Seq[ExecutorInfo] = {
87
- removedExecutors.filter(_.state == ExecutorState.EXITED)
88
- }
89
-
90
private val myMaxCores = desc.maxCores.getOrElse(defaultCores)
91
92
def coresLeft: Int = myMaxCores - coresGranted
0 commit comments