dongjoon-hyun commented on code in PR #56628:
URL: https://github.com/apache/spark/pull/56628#discussion_r3623911351
##########
core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala:
##########
@@ -1057,6 +1057,12 @@ 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))} failed because while it
was being launched," +
+ log" its executor was shutting down. " +
Review Comment:
It sounds a little strange. Could you revise to "failed because its executor
was shutting down while the task was being launched."?
--
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]
