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 227b40d commit a5f7c8cCopy full SHA for a5f7c8c
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1001,7 +1001,6 @@ class DAGScheduler(
1001
val stageId = task.stageId
1002
val taskType = Utils.getFormattedClassName(task)
1003
1004
- // REVIEWERS: does this need special handling for multiple completions of the same task?
1005
outputCommitCoordinator.taskCompleted(stageId, task.partitionId,
1006
event.taskInfo.attempt, event.reason)
1007
0 commit comments