Skip to content
Snippets Groups Projects
Commit 5e67cdc8 authored by Reynold Xin's avatar Reynold Xin
Browse files

Merge pull request #319 from kayousterhout/remove_error_method

Removed redundant TaskSetManager.error() function.

This function was leftover from a while ago, and now just
passes all calls through to the abort() function, so this
commit deletes it.
parents 3713f812 5a3c00c9
No related branches found
No related tags found
No related merge requests found
......@@ -328,7 +328,7 @@ private[spark] class TaskSchedulerImpl(
// Have each task set throw a SparkException with the error
for ((taskSetId, manager) <- activeTaskSets) {
try {
manager.error(message)
manager.abort(message)
} catch {
case e: Exception => logError("Exception in error callback", e)
}
......
......@@ -548,11 +548,6 @@ private[spark] class TaskSetManager(
}
}
def error(message: String) {
// Save the error message
abort("Error: " + message)
}
def abort(message: String) {
// TODO: Kill running tasks if we were not terminated due to a Mesos error
sched.dagScheduler.taskSetFailed(taskSet, message)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment