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 73ceda8 commit 0b8a46bCopy full SHA for 0b8a46b
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) {//} || hasNodeLocalOnlyTasks) {
420
allowedLocality = getAllowedLocalityLevel(curTime)
421
if (allowedLocality > maxLocality) {
422
// We're not allowed to search for farther-away tasks
0 commit comments