Github user jerryshao commented on a diff in the pull request:
https://github.com/apache/spark/pull/19338#discussion_r141234485
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala ---
@@ -670,9 +670,12 @@ private[spark] class TaskSetManager(
}
if (blacklistedEverywhere) {
val partition = tasks(indexInTaskSet).partitionId
- abort(s"Aborting $taskSet because task $indexInTaskSet
(partition $partition) " +
- s"cannot run anywhere due to node and executor blacklist.
Blacklisting behavior " +
- s"can be configured via spark.blacklist.*.")
+ abort(s"""
+ |Aborting $taskSet because task $indexInTaskSet (partition
$partition)
+ |cannot run anywhere due to node and executor blacklist.
+ |Most recent failure:
+ |${taskSetBlacklist.getLatestFailureReason}\n
--- End diff --
You don't have to add "\n", since you already use triple quoted format.
Please trying to get understand the basic of this API before modifying it.
Also verified in locally before pushing a new commit, and update the PR
description to reflect your new format accordingly.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
