Skip to content

JobListener

JobListener is an abstraction of listeners that listen for job completion or failure events (after submitting a job to the DAGScheduler).

Contract

taskSucceeded

taskSucceeded(
  index: Int,
  result: Any): Unit

Used when DAGScheduler is requested to handleTaskCompletion or markMapStageJobAsFinished

jobFailed

jobFailed(
  exception: Exception): Unit

Used when DAGScheduler is requested to cleanUpAfterSchedulerStop, handleJobSubmitted, handleMapStageSubmitted, handleTaskCompletion or failJobAndIndependentStages

Implementations