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 cf0d6ac commit 539a578Copy full SHA for 539a578
core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala
@@ -740,7 +740,7 @@ private[spark] class TaskSetManager(
740
levels.toArray
741
}
742
743
- //Re-compute the pending lists. This should be called when new executor is added
+ // Re-compute the pending lists. This should be called when new executor is added
744
def reAddPendingTasks() {
745
logInfo("Re-computing pending task lists.")
746
for (i <- (0 until numTasks).reverse.filter(index => copiesRunning(index) == 0
0 commit comments