cloud-fan commented on code in PR #43954: URL: https://github.com/apache/spark/pull/43954#discussion_r1448202496
########## core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala: ########## @@ -296,18 +296,31 @@ private[spark] class TaskSchedulerImpl( new TaskSetManager(this, taskSet, maxTaskFailures, healthTrackerOpt, clock) } - override def cancelTasks( + // Kill all the tasks in all the stage attempts of the same stage Id. Note stage attempts won't + // be aborted but will be marked as zombie. The stage attempt will be finished and cleaned up + // once all the tasks has been finished. The stage attempt could be aborted after the call of + // `cancelTasks` if required. Review Comment: ```suggestion // `killAllTaskAttempts ` if required. ``` -- 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: reviews-unsubscr...@spark.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org