Test Result : SparkListenerSuite

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

All Tests

Test nameDurationStatus
SPARK-30285: Fix deadlock in AsyncEventQueue.removeListenerOnError: set Thread interrupted12 msPassed
SPARK-30285: Fix deadlock in AsyncEventQueue.removeListenerOnError: throw interrupt13 msPassed
SparkListener moves on if a listener throws an exception11 msPassed
StageInfo with fewer tasks than partitions62 msPassed
add and remove listeners to/from LiveListenerBus queues2 msPassed
basic creation and shutdown of LiveListenerBus5 msPassed
basic creation of StageInfo0.1 secPassed
basic creation of StageInfo with shuffle0.14 secPassed
bus.stop() waits for the event queue to completely drain2 msPassed
don't call sc.stop in listener75 msPassed
event queue size can be configured through spark conf2 msPassed
interrupt within listener is handled correctly: set Thread interrupted22 msPassed
interrupt within listener is handled correctly: throw interrupt22 msPassed
local metrics1.4 secPassed
metrics for dropped listener events3 msPassed
onTaskEnd() should be called for all started tasks, even after job has been killed46 msPassed
onTaskGettingResult() called when result fetched remotely0.13 secPassed
onTaskGettingResult() not called when result sent directly47 msPassed
registering listeners via spark.extraListeners41 msPassed