Removed redundant job.listener.jobFailed notification

alteryx · Jul 2, 2013 · 5c11932 · 5c11932
1 parent 3d8bc99
commit 5c11932
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala
@@ -676,7 +676,6 @@ class DAGScheduler(
       activeJobs -= job
       resultStageToJob -= resultStage
       removeStages(job)
-      job.listener.jobFailed(new SparkException("Job failed: " + reason))
     }
     if (dependentStages.isEmpty) {
       logInfo("Ignoring failure of " + failedStage + " because all jobs depending on it are done")