Package org.apache.flink.runtime.highavailability

Interface Summary

Interface	Description
HighAvailabilityServices	The HighAvailabilityServices give access to all services needed for a highly-available setup.
RunningJobsRegistry	A simple registry that tracks if a certain job is pending execution, running, or completed.

Class Summary

Class	Description
FsNegativeRunningJobsRegistry	This RunningJobsRegistry tracks the status jobs via marker files, marking running jobs viarunning marker files, marking finished jobs via finished marker files.
HighAvailabilityServicesUtils	Utils class to instantiate HighAvailabilityServices implementations.
ServicesThreadFactory

Enum Summary

Enum	Description
HighAvailabilityServicesUtils.AddressResolution
RunningJobsRegistry.JobSchedulingStatus	The scheduling status of a job, as maintained by the RunningJobsRegistry.

Exception Summary

Exception	Description
LeaderIdMismatchException	An exception thrown when the leader session id attached to a message does not match the leader session id that the receiver expects.