public interface ResourceEventHandler<WorkerType extends ResourceIDRetrievable>
|Modifier and Type||Method and Description|
Notifies that an error has occurred that the process cannot proceed.
Notifies that workers of previous attempt have been recovered from the external resource manager.
Notifies that the worker has been terminated.
void onPreviousAttemptWorkersRecovered(Collection<WorkerType> recoveredWorkers)
recoveredWorkers- Collection of worker nodes, in the deployment specific type.
void onWorkerTerminated(ResourceID resourceId, String diagnostics)
resourceId- Identifier of the terminated worker.
diagnostics- Diagnostic message about the worker termination.
void onError(Throwable exception)
exception- Exception that describes the error.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.