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 9b9432f commit 87dd09eCopy full SHA for 87dd09e
core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala
@@ -416,7 +416,7 @@ private[spark] class TaskSetManager(
416
417
var allowedLocality = maxLocality
418
419
- if (maxLocality != TaskLocality.NO_PREF) { //} || hasNodeLocalOnlyTasks) {
+ if (maxLocality != TaskLocality.NO_PREF) {
420
allowedLocality = getAllowedLocalityLevel(curTime)
421
if (allowedLocality > maxLocality) {
422
// We're not allowed to search for farther-away tasks
0 commit comments