Skip to content

Commit 2f019d5

Browse files
committed
Address tgraves review comments
1 parent 0d07845 commit 2f019d5

File tree

2 files changed

+2
-9
lines changed

2 files changed

+2
-9
lines changed

core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -882,13 +882,6 @@ private[spark] class ExecutorAllocationManager(
882882
attempts.filter(attempt => unschedulableTaskSets.contains(attempt)).size
883883
}
884884

885-
def hasPendingUnschedulableTasks: Boolean = {
886-
val attemptSets = resourceProfileIdToStageAttempt.values
887-
attemptSets.exists { attempts =>
888-
attempts.exists(unschedulableTaskSets.contains(_))
889-
}
890-
}
891-
892885
def hasPendingTasks: Boolean = {
893886
hasPendingSpeculativeTasks || hasPendingRegularTasks
894887
}

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1041,8 +1041,8 @@ private[spark] class DAGScheduler(
10411041
}
10421042

10431043
private[scheduler] def handleUnschedulableTaskSetRemoved(
1044-
stageId: Int,
1045-
stageAttemptId: Int): Unit = {
1044+
stageId: Int,
1045+
stageAttemptId: Int): Unit = {
10461046
listenerBus.post(SparkListenerUnschedulableTaskSetRemoved(stageId, stageAttemptId))
10471047
}
10481048

0 commit comments

Comments
 (0)