We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9217080 commit f33d844Copy full SHA for f33d844
1 file changed
core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
@@ -97,6 +97,7 @@ class DAGSchedulerSuite extends FunSuite with BeforeAndAfter with LocalSparkCont
97
before {
98
sc = new SparkContext("local", "DAGSchedulerSuite")
99
taskSets.clear()
100
+ cancelledStages.clear()
101
cacheLocations.clear()
102
results.clear()
103
mapOutputTracker = new MapOutputTrackerMaster(conf)
@@ -346,7 +347,6 @@ class DAGSchedulerSuite extends FunSuite with BeforeAndAfter with LocalSparkCont
346
347
test("run shuffle with map stage failure") {
348
val shuffleMapRdd = makeRdd(2, Nil)
349
val shuffleDep = new ShuffleDependency(shuffleMapRdd, null)
- val shuffleId = shuffleDep.shuffleId
350
val reduceRdd = makeRdd(2, List(shuffleDep))
351
submit(reduceRdd, Array(0, 1))
352
0 commit comments