Skip to content
Snippets Groups Projects
Commit 5a3c00c9 authored by Kay Ousterhout's avatar Kay Ousterhout
Browse files

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.
parent 3713f812
No related branches found
No related tags found
No related merge requests found
...@@ -328,7 +328,7 @@ private[spark] class TaskSchedulerImpl( ...@@ -328,7 +328,7 @@ private[spark] class TaskSchedulerImpl(
// Have each task set throw a SparkException with the error // Have each task set throw a SparkException with the error
for ((taskSetId, manager) <- activeTaskSets) { for ((taskSetId, manager) <- activeTaskSets) {
try { try {
manager.error(message) manager.abort(message)
} catch { } catch {
case e: Exception => logError("Exception in error callback", e) case e: Exception => logError("Exception in error callback", e)
} }
......
...@@ -548,11 +548,6 @@ private[spark] class TaskSetManager( ...@@ -548,11 +548,6 @@ private[spark] class TaskSetManager(
} }
} }
def error(message: String) {
// Save the error message
abort("Error: " + message)
}
def abort(message: String) { def abort(message: String) {
// TODO: Kill running tasks if we were not terminated due to a Mesos error // TODO: Kill running tasks if we were not terminated due to a Mesos error
sched.dagScheduler.taskSetFailed(taskSet, message) 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