org.apache.flink.runtime.rpc

Interface FatalErrorHandler

All Known Implementing Classes:

ApplicationClusterEntryPoint, ClusterEntrypoint, JobClusterEntrypoint, KubernetesApplicationClusterEntrypoint, KubernetesSessionClusterEntrypoint, SessionClusterEntrypoint, StandaloneApplicationClusterEntryPoint, StandaloneSessionClusterEntrypoint, TaskManagerRunner, YarnApplicationClusterEntryPoint, YarnJobClusterEntrypoint, YarnSessionClusterEntrypoint

public interface FatalErrorHandler

Handler for fatal errors.

Method Summary

Modifier and Type	Method and Description
void	onFatalError(Throwable exception) Being called when a fatal error occurs.

Method Detail

onFatalError

void onFatalError(Throwable exception)

Being called when a fatal error occurs.

IMPORTANT: This call should never be blocking since it might be called from within the main thread of an RpcEndpoint.

Parameters:

exception - cause