re-trigger the test.....

CodingCat · CodingCat · commit 5d1636adabf0 · 2014-04-22T15:07:50.000-04:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1140,7 +1140,7 @@ private[scheduler] class DAGSchedulerEventProcessActor(dagScheduler: DAGSchedule
   }
 
   override def postStop() {
-    // Cancel any active jobs
+    // Cancel any active jobs in postStop hook
     for (job <- dagScheduler.activeJobs) {
       val error = new SparkException("Job cancelled because SparkContext was shut down")
       job.listener.jobFailed(error)

Original file line number	Diff line number	Diff line change
`@@ -1140,7 +1140,7 @@ private[scheduler] class DAGSchedulerEventProcessActor(dagScheduler: DAGSchedule`
`1140`	`1140`	`}`
`1141`	`1141`
`1142`	`1142`	`override def postStop() {`
`1143`		`- // Cancel any active jobs`
	`1143`	`+ // Cancel any active jobs in postStop hook`
`1144`	`1144`	`for (job <- dagScheduler.activeJobs) {`
`1145`	`1145`	`val error = new SparkException("Job cancelled because SparkContext was shut down")`
`1146`	`1146`	`job.listener.jobFailed(error)`