ExecutorPodsWatcher is an internal class of ExecutorPodsWatchSnapshotSource with full access to its internals.
ExecutorPodsWatcher takes no arguments to be created.
ExecutorPodsWatcher is created when:
ExecutorPodsWatchSnapshotSourceis requested to start
Executor Pod Update¶
eventReceived( action: Action, pod: Pod): Unit
eventReceived is part of the Kubernetes Client
eventReceived prints out the following DEBUG message to the logs:
Received executor pod update for pod named [podName], action [action]
onClose( e: KubernetesClientException): Unit
onClose is part of the Kubernetes Client
onClose prints out the following WARN message to the logs:
Kubernetes client has been closed (this is expected if the application is shutting down.)
ExecutorPodsWatcher uses org.apache.spark.scheduler.cluster.k8s.ExecutorPodsWatchSnapshotSource logger for logging.