We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e61f7f8 commit cc353c8Copy full SHA for cc353c8
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1065,7 +1065,8 @@ class DAGScheduler(
1065
try { // cancelTasks will fail if a SchedulerBackend does not implement killTask
1066
taskScheduler.cancelTasks(stageId, shouldInterruptThread)
1067
} catch {
1068
- case e: UnsupportedOperationException => logInfo(s"Could not cancel tasks for stage $stageId", e)
+ case e: UnsupportedOperationException =>
1069
+ logInfo(s"Could not cancel tasks for stage $stageId", e)
1070
} finally {
1071
val stageInfo = stageToInfos(stage)
1072
stageInfo.stageFailed(failureReason)
0 commit comments