Package org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderElectionHaServices

java.lang.Object

org.apache.flink.runtime.highavailability.AbstractHaServices

org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionHaServices

All Implemented Interfaces:

AutoCloseable, org.apache.flink.runtime.dispatcher.cleanup.GloballyCleanableResource, org.apache.flink.runtime.highavailability.ClientHighAvailabilityServices, org.apache.flink.runtime.highavailability.HighAvailabilityServices

public class KubernetesLeaderElectionHaServices
extends org.apache.flink.runtime.highavailability.AbstractHaServices

Kubernetes HA services that use a single leader election service per JobManager.

Field Summary

Fields inherited from class org.apache.flink.runtime.highavailability.AbstractHaServices

configuration, ioExecutor, logger

Fields inherited from interface org.apache.flink.runtime.highavailability.HighAvailabilityServices

DEFAULT_JOB_ID, DEFAULT_LEADER_ID

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory	createCheckpointRecoveryFactory()
protected org.apache.flink.runtime.jobmanager.JobGraphStore	createJobGraphStore()
protected org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService	createLeaderRetrievalService(String componentId)
protected String	getLeaderPathForDispatcher()
protected String	getLeaderPathForJobManager(org.apache.flink.api.common.JobID jobID)
protected String	getLeaderPathForResourceManager()
protected String	getLeaderPathForRestServer()
void	internalCleanup()
void	internalCleanupJobData(org.apache.flink.api.common.JobID jobID)
void	internalClose()

Methods inherited from class org.apache.flink.runtime.highavailability.AbstractHaServices

cleanupAllData, close, createBlobStore, getCheckpointRecoveryFactory, getClusterRestEndpointLeaderElection, getClusterRestEndpointLeaderRetriever, getDispatcherLeaderElection, getDispatcherLeaderRetriever, getJobGraphStore, getJobManagerLeaderElection, getJobManagerLeaderRetriever, getJobManagerLeaderRetriever, getJobResultStore, getResourceManagerLeaderElection, getResourceManagerLeaderRetriever, globalCleanupAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.highavailability.HighAvailabilityServices

closeWithOptionalClean, getWebMonitorLeaderElection, getWebMonitorLeaderRetriever

Method Detail

createLeaderRetrievalService

protected org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService createLeaderRetrievalService(String componentId)

Specified by:

createLeaderRetrievalService in class org.apache.flink.runtime.highavailability.AbstractHaServices

createCheckpointRecoveryFactory

protected org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory createCheckpointRecoveryFactory()

Specified by:

createCheckpointRecoveryFactory in class org.apache.flink.runtime.highavailability.AbstractHaServices

createJobGraphStore

protected org.apache.flink.runtime.jobmanager.JobGraphStore createJobGraphStore()
                                                                         throws Exception

Specified by:

createJobGraphStore in class org.apache.flink.runtime.highavailability.AbstractHaServices

Throws:

Exception

internalClose

public void internalClose()
                   throws Exception

Specified by:

internalClose in class org.apache.flink.runtime.highavailability.AbstractHaServices

Throws:

Exception

internalCleanup

public void internalCleanup()
                     throws Exception

Specified by:

internalCleanup in class org.apache.flink.runtime.highavailability.AbstractHaServices

Throws:

Exception

internalCleanupJobData

public void internalCleanupJobData(org.apache.flink.api.common.JobID jobID)
                            throws Exception

Specified by:

internalCleanupJobData in class org.apache.flink.runtime.highavailability.AbstractHaServices

Throws:

Exception

getLeaderPathForResourceManager

protected String getLeaderPathForResourceManager()

Specified by:

getLeaderPathForResourceManager in class org.apache.flink.runtime.highavailability.AbstractHaServices

getLeaderPathForDispatcher

protected String getLeaderPathForDispatcher()

Specified by:

getLeaderPathForDispatcher in class org.apache.flink.runtime.highavailability.AbstractHaServices

getLeaderPathForJobManager

protected String getLeaderPathForJobManager(org.apache.flink.api.common.JobID jobID)

Specified by:

getLeaderPathForJobManager in class org.apache.flink.runtime.highavailability.AbstractHaServices

getLeaderPathForRestServer

protected String getLeaderPathForRestServer()

Specified by:

getLeaderPathForRestServer in class org.apache.flink.runtime.highavailability.AbstractHaServices