Test Result : SparkListenerSuite

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

All Tests

Test nameDurationStatus
SparkListener moves on if a listener throws an exception12 msPassed
StageInfo with fewer tasks than partitions67 msPassed
add and remove listeners to/from LiveListenerBus queues1 msPassed
basic creation and shutdown of LiveListenerBus15 msPassed
basic creation of StageInfo0.1 secPassed
basic creation of StageInfo with shuffle0.13 secPassed
event queue size can be configued through spark conf2 msPassed
extraListeners44 msPassed
interrupt within listener is handled correctly: set Thread interrupted22 msPassed
interrupt within listener is handled correctly: throw interrupt22 msPassed
local metrics1.2 secPassed
metrics for dropped listener events3 msPassed
onTaskEnd() should be called for all started tasks, even after job has been killed49 msPassed
onTaskGettingResult() called when result fetched remotely0.36 secPassed
onTaskGettingResult() not called when result sent directly54 msPassed
removeListenerOnError: set Thread interrupted12 msPassed
removeListenerOnError: throw interrupt13 msPassed
stop in listener62 msPassed
stop() waits for the event queue to completely drain3 msPassed