Skip to content

ExecutorAllocationListener

ExecutorAllocationListener is a SparkListener.md[] that intercepts events about stages, tasks, and executors, i.e. onStageSubmitted, onStageCompleted, onTaskStart, onTaskEnd, onExecutorAdded, and onExecutorRemoved. Using the events ExecutorAllocationManager can manage the pool of dynamically managed executors.

Internal Class

ExecutorAllocationListener is an internal class of ExecutorAllocationManager with full access to internal registries.