Github user CodingCat commented on the pull request:
https://github.com/apache/spark/pull/1313#issuecomment-50978501
I might give more explanation on the trace printed above
Set()
ANY,NODE_LOCAL
task 1, ArrayBuffer()
task 0, ArrayBuffer(TaskLocation(localhost, None))
miss task
======
the first line is speculative tasks,
the second line, maxLocality, allowedLocality
the third to the second last line are the tasks in the allPendingTasks and
their locality preference
the last line is whether the tasksetManager finds a task
From the trace above, we can see that, the nonPref tasks indeed experience
unnecessary delay, causing the test case being interrupted
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
