File tree 1 file changed +2
-2
lines changed
core/src/test/scala/org/apache/spark/scheduler
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -3378,7 +3378,7 @@ class DAGSchedulerSuite extends SparkFunSuite with TempLocalSparkContext with Ti
3378
3378
// As the ShuffleMapStage is inDeterminate all the partitions need to be retried
3379
3379
assert(failedStages.collect {
3380
3380
case stage : ShuffleMapStage if stage.shuffleDep.shuffleId == shuffleId2 => stage
3381
- }.head.findMissingPartitions() == Seq (0 , 1 ))
3381
+ }.head.findMissingPartitions() == Seq (0 ))
3382
3382
// The result stage is still waiting for its 2 tasks to complete
3383
3383
assert(failedStages.collect {
3384
3384
case stage : ResultStage => stage
@@ -4350,7 +4350,7 @@ class DAGSchedulerSuite extends SparkFunSuite with TempLocalSparkContext with Ti
4350
4350
// As the ShuffleMapStage is inDeterminate all the partitions need to be retried
4351
4351
assert(failedStages.collect {
4352
4352
case stage : ShuffleMapStage if stage.shuffleDep.shuffleId == shuffleId2 => stage
4353
- }.head.findMissingPartitions() == Seq (0 , 1 ))
4353
+ }.head.findMissingPartitions() == Seq (0 ))
4354
4354
// The result stage is still waiting for its 2 tasks to complete
4355
4355
assert(failedStages.collect {
4356
4356
case stage : ResultStage => stage
You can’t perform that action at this time.
0 commit comments