Test Result : SparkListenerSuite

0 failures (±0)
19 tests (±0)
Took 13 sec.

All Tests

Test nameDurationStatus
SparkListener moves on if a listener throws an exception27 msPassed
StageInfo with fewer tasks than partitions0.5 secPassed
add and remove listeners to/from LiveListenerBus queues5 msPassed
basic creation and shutdown of LiveListenerBus18 msPassed
basic creation of StageInfo1.3 secPassed
basic creation of StageInfo with shuffle4 secPassed
event queue size can be configued through spark conf3 msPassed
extraListeners0.32 secPassed
interrupt within listener is handled correctly: set Thread interrupted46 msPassed
interrupt within listener is handled correctly: throw interrupt25 msPassed
local metrics4.4 secPassed
metrics for dropped listener events20 msPassed
onTaskEnd() should be called for all started tasks, even after job has been killed0.48 secPassed
onTaskGettingResult() called when result fetched remotely1.1 secPassed
onTaskGettingResult() not called when result sent directly0.44 secPassed
removeListenerOnError: set Thread interrupted19 msPassed
removeListenerOnError: throw interrupt15 msPassed
stop in listener0.58 secPassed
stop() waits for the event queue to completely drain21 msPassed