Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19338#discussion_r140823560
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/TaskSetBlacklist.scala ---
@@ -94,7 +96,9 @@ private[scheduler] class TaskSetBlacklist(val conf:
SparkConf, val stageId: Int,
private[scheduler] def updateBlacklistForFailedTask(
host: String,
exec: String,
- index: Int): Unit = {
+ index: Int,
+ failureReason: Option[String] = None): Unit = {
--- End diff --
`failureReason` should always be present in this call, so it shouldn't be
an `Option` as an arg to this method.
(I realize this is a bit of a pain as you have to modify all the call sites
in tests, sorry about that).
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
