Update DAGSchedulerSuite

aarondav · aarondav · commit 82f78bb67681 · 2014-04-23T13:49:41.000-07:00
diff --git a/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
@@ -58,7 +58,7 @@ class DAGSchedulerSuite extends FunSuite with BeforeAndAfter with LocalSparkCont
       taskSet.tasks.foreach(_.epoch = mapOutputTracker.getEpoch)
       taskSets += taskSet
     }
-    override def cancelTasks(stageId: Int) {
+    override def cancelTasks(stageId: Int, interruptThread: Boolean) {
       cancelledStages += stageId
     }
     override def setDAGScheduler(dagScheduler: DAGScheduler) = {}

Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ class DAGSchedulerSuite extends FunSuite with BeforeAndAfter with LocalSparkCont`
`58`	`58`	`taskSet.tasks.foreach(_.epoch = mapOutputTracker.getEpoch)`
`59`	`59`	`taskSets += taskSet`
`60`	`60`	`}`
`61`		`- override def cancelTasks(stageId: Int) {`
	`61`	`+ override def cancelTasks(stageId: Int, interruptThread: Boolean) {`
`62`	`62`	`cancelledStages += stageId`
`63`	`63`	`}`
`64`	`64`	`override def setDAGScheduler(dagScheduler: DAGScheduler) = {}`