Skip to content

Commit

Permalink
remove extra spaces
Browse files Browse the repository at this point in the history
  • Loading branch information
Thomas Graves committed Mar 14, 2016
1 parent 4d5e402 commit 68b64ae
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1144,10 +1144,10 @@ class DAGScheduler(
null
}

// The stage may have already finished when we get this event -- eg. maybe it was a
// speculative task. It is important that we send the TaskEnd event in any case, so listeners
// The stage may have already finished when we get this event -- eg. maybe it was a
// speculative task. It is important that we send the TaskEnd event in any case, so listeners
// are properly notified and can chose to handle it. For instance, some listeners are
// doing their own accounting and if they don't get the task end event they think
// doing their own accounting and if they don't get the task end event they think
// tasks are still running when they really aren't.
listenerBus.post(SparkListenerTaskEnd(
stageId, task.stageAttemptId, taskType, event.reason, event.taskInfo, taskMetrics))
Expand Down

0 comments on commit 68b64ae

Please sign in to comment.