@@ -586,12 +586,12 @@ class DAGSchedulerSuite
586
586
Map [Long , Any ](),
587
587
createFakeTaskInfo(),
588
588
null ))
589
- assert( sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS ) )
589
+ sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS )
590
590
assert(sparkListener.failedStages.contains(1 ))
591
591
592
592
// Trigger resubmission of the failed map stage.
593
593
runEvent(ResubmitFailedStages )
594
- assert( sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS ) )
594
+ sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS )
595
595
596
596
// Another attempt for the map stage should have been submitted, resulting in 2 total attempts.
597
597
assert(countSubmittedMapStageAttempts() === 2 )
@@ -608,7 +608,7 @@ class DAGSchedulerSuite
608
608
// Another ResubmitFailedStages event should not result result in another attempt for the map
609
609
// stage being run concurrently.
610
610
runEvent(ResubmitFailedStages )
611
- assert( sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS ) )
611
+ sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS )
612
612
assert(countSubmittedMapStageAttempts() === 2 )
613
613
614
614
// NOTE: the actual ResubmitFailedStages may get called at any time during this, shouldn't effect anything --
@@ -634,7 +634,7 @@ class DAGSchedulerSuite
634
634
}
635
635
636
636
// The map stage should have been submitted.
637
- assert( sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS ) )
637
+ sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS )
638
638
assert(countSubmittedMapStageAttempts() === 1 )
639
639
640
640
// Complete the map stage.
@@ -643,7 +643,7 @@ class DAGSchedulerSuite
643
643
(Success , makeMapStatus(" hostB" , 1 ))))
644
644
645
645
// The reduce stage should have been submitted.
646
- assert( sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS ) )
646
+ sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS )
647
647
assert(countSubmittedReduceStageAttempts() === 1 )
648
648
649
649
// The first result task fails, with a fetch failure for the output from the first mapper.
@@ -661,7 +661,7 @@ class DAGSchedulerSuite
661
661
662
662
// Because the map stage finished, another attempt for the reduce stage should have been
663
663
// submitted, resulting in 2 total attempts for each the map and the reduce stage.
664
- assert( sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS ) )
664
+ sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS )
665
665
assert(countSubmittedMapStageAttempts() === 2 )
666
666
assert(countSubmittedReduceStageAttempts() === 2 )
667
667
0 commit comments