uros-b commented on code in PR #56628:
URL: https://github.com/apache/spark/pull/56628#discussion_r3466179437
##########
core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala:
##########
@@ -1057,6 +1057,11 @@ private[spark] class TaskSetManager(
log"Not counting this failure towards the maximum number of failures
for the task.")
None
+ case _: ExecutorShutdownFailure =>
+ logInfo(log"${MDC(TASK_NAME, taskName(tid))} was rejected because its
executor was" +
+ log" shutting down. Not counting this towards the maximum number of
failures.")
Review Comment:
Cosmetic alignment nit: the new log message ("Not counting this towards the
maximum number of failures") differs slightly in wording from the adjacent
ExecutorLostFailure message ("...towards the maximum number of failures for the
task.").
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
