Uses of Interface
org.apache.flink.runtime.highavailability.HighAvailabilityServices

Packages that use HighAvailabilityServices

Package	Description
org.apache.flink.kubernetes.highavailability
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.cleanup
org.apache.flink.runtime.entrypoint
org.apache.flink.runtime.entrypoint.component
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha
org.apache.flink.runtime.highavailability.nonha.embedded
org.apache.flink.runtime.highavailability.nonha.standalone
org.apache.flink.runtime.highavailability.zookeeper
org.apache.flink.runtime.jobmanager
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.factories
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.taskexecutor

Uses of HighAvailabilityServices in org.apache.flink.kubernetes.highavailability

Classes in org.apache.flink.kubernetes.highavailability that implement HighAvailabilityServices

Modifier and Type	Class and Description
class	KubernetesMultipleComponentLeaderElectionHaServices Kubernetes HA services that use a single leader election service per JobManager.

Methods in org.apache.flink.kubernetes.highavailability that return HighAvailabilityServices

Modifier and Type	Method and Description
HighAvailabilityServices	KubernetesMultipleComponentLeaderElectionHaServicesFactory.createHAServices(Configuration configuration, Executor executor)
HighAvailabilityServices	KubernetesHaServicesFactory.createHAServices(Configuration configuration, Executor executor)

Uses of HighAvailabilityServices in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher that return HighAvailabilityServices

Modifier and Type	Method and Description
HighAvailabilityServices	DispatcherServices.getHighAvailabilityServices()
HighAvailabilityServices	PartialDispatcherServices.getHighAvailabilityServices()

Methods in org.apache.flink.runtime.dispatcher with parameters of type HighAvailabilityServices

Modifier and Type	Method and Description
JobManagerRunner	JobMasterServiceLeadershipRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, long initializationTimestamp)
JobManagerRunner	JobManagerRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, long initializationTimestamp)

Constructors in org.apache.flink.runtime.dispatcher with parameters of type HighAvailabilityServices

Constructor and Description

PartialDispatcherServices(Configuration configuration, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroupFactory jobManagerMetricGroupFactory, ExecutionGraphInfoStore executionGraphInfoStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist, String metricQueryServiceAddress, Executor ioExecutor, DispatcherOperationCaches operationCaches)

Uses of HighAvailabilityServices in org.apache.flink.runtime.dispatcher.cleanup

Constructors in org.apache.flink.runtime.dispatcher.cleanup with parameters of type HighAvailabilityServices

Constructor and Description
DispatcherResourceCleanerFactory(Executor cleanupExecutor, RetryStrategy retryStrategy, JobManagerRunnerRegistry jobManagerRunnerRegistry, JobGraphWriter jobGraphWriter, BlobServer blobServer, HighAvailabilityServices highAvailabilityServices, JobManagerMetricGroup jobManagerMetricGroup)

Uses of HighAvailabilityServices in org.apache.flink.runtime.entrypoint

Methods in org.apache.flink.runtime.entrypoint that return HighAvailabilityServices

Modifier and Type	Method and Description
protected HighAvailabilityServices	ClusterEntrypoint.createHaServices(Configuration configuration, Executor executor, RpcSystemUtils rpcSystemUtils)

Uses of HighAvailabilityServices in org.apache.flink.runtime.entrypoint.component

Methods in org.apache.flink.runtime.entrypoint.component with parameters of type HighAvailabilityServices

Modifier and Type	Method and Description
DispatcherResourceManagerComponent	DispatcherResourceManagerComponentFactory.create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
DispatcherResourceManagerComponent	DefaultDispatcherResourceManagerComponentFactory.create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)

Uses of HighAvailabilityServices in org.apache.flink.runtime.highavailability

Classes in org.apache.flink.runtime.highavailability that implement HighAvailabilityServices

Modifier and Type	Class and Description
class	AbstractHaServices Abstract high availability services based on distributed system(e.g.

Methods in org.apache.flink.runtime.highavailability that return HighAvailabilityServices

Modifier and Type	Method and Description
static HighAvailabilityServices	HighAvailabilityServicesUtils.createAvailableOrEmbeddedServices(Configuration config, Executor executor, FatalErrorHandler fatalErrorHandler)
HighAvailabilityServices	HighAvailabilityServicesFactory.createHAServices(Configuration configuration, Executor executor) Creates a HighAvailabilityServices instance.
static HighAvailabilityServices	HighAvailabilityServicesUtils.createHighAvailabilityServices(Configuration configuration, Executor executor, AddressResolution addressResolution, RpcSystemUtils rpcSystemUtils, FatalErrorHandler fatalErrorHandler)

Uses of HighAvailabilityServices in org.apache.flink.runtime.highavailability.nonha

Classes in org.apache.flink.runtime.highavailability.nonha that implement HighAvailabilityServices

Modifier and Type	Class and Description
class	AbstractNonHaServices Abstract base class for non high-availability services.

Uses of HighAvailabilityServices in org.apache.flink.runtime.highavailability.nonha.embedded

Classes in org.apache.flink.runtime.highavailability.nonha.embedded that implement HighAvailabilityServices

Modifier and Type	Class and Description
class	EmbeddedHaServices An implementation of the HighAvailabilityServices for the non-high-availability case where all participants (ResourceManager, JobManagers, TaskManagers) run in the same process.
class	EmbeddedHaServicesWithLeadershipControl EmbeddedHaServices extension to expose leadership granting and revoking.

Uses of HighAvailabilityServices in org.apache.flink.runtime.highavailability.nonha.standalone

Classes in org.apache.flink.runtime.highavailability.nonha.standalone that implement HighAvailabilityServices

Modifier and Type	Class and Description
class	StandaloneHaServices An implementation of the HighAvailabilityServices for the non-high-availability case.

Uses of HighAvailabilityServices in org.apache.flink.runtime.highavailability.zookeeper

Classes in org.apache.flink.runtime.highavailability.zookeeper that implement HighAvailabilityServices

Modifier and Type	Class and Description
class	AbstractZooKeeperHaServices Abstract ZooKeeper based HA services.
class	ZooKeeperMultipleComponentLeaderElectionHaServices ZooKeeper HA services that only use a single leader election per process.

Uses of HighAvailabilityServices in org.apache.flink.runtime.jobmanager

Constructors in org.apache.flink.runtime.jobmanager with parameters of type HighAvailabilityServices

Constructor and Description
HaServicesJobPersistenceComponentFactory(HighAvailabilityServices highAvailabilityServices)

Uses of HighAvailabilityServices in org.apache.flink.runtime.jobmaster

Constructors in org.apache.flink.runtime.jobmaster with parameters of type HighAvailabilityServices

Constructor and Description

JobMaster(RpcService rpcService, JobMasterId jobMasterId, JobMasterConfiguration jobMasterConfiguration, ResourceID resourceId, JobGraph jobGraph, HighAvailabilityServices highAvailabilityService, SlotPoolServiceSchedulerFactory slotPoolServiceSchedulerFactory, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, JobManagerJobMetricGroupFactory jobMetricGroupFactory, OnCompletionActions jobCompletionActions, FatalErrorHandler fatalErrorHandler, ClassLoader userCodeLoader, ShuffleMaster<?> shuffleMaster, PartitionTrackerFactory partitionTrackerFactory, ExecutionDeploymentTracker executionDeploymentTracker, ExecutionDeploymentReconciler.Factory executionDeploymentReconcilerFactory, BlocklistHandler.Factory blocklistHandlerFactory, long initializationTimestamp)

Uses of HighAvailabilityServices in org.apache.flink.runtime.jobmaster.factories

Constructors in org.apache.flink.runtime.jobmaster.factories with parameters of type HighAvailabilityServices

Constructor and Description

DefaultJobMasterServiceFactory(Executor executor, RpcService rpcService, JobMasterConfiguration jobMasterConfiguration, JobGraph jobGraph, HighAvailabilityServices haServices, SlotPoolServiceSchedulerFactory slotPoolServiceSchedulerFactory, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, ClassLoader userCodeClassloader, long initializationTimestamp)

Uses of HighAvailabilityServices in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster that return HighAvailabilityServices

Modifier and Type	Method and Description
protected HighAvailabilityServices	MiniCluster.createHighAvailabilityServices(Configuration configuration, Executor executor)
protected HighAvailabilityServices	MiniCluster.getHaServices()

Uses of HighAvailabilityServices in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager that return HighAvailabilityServices

Modifier and Type	Method and Description
HighAvailabilityServices	ResourceManagerProcessContext.getHighAvailabilityServices()

Methods in org.apache.flink.runtime.resourcemanager with parameters of type HighAvailabilityServices

Modifier and Type	Method and Description
static ResourceManagerServiceImpl	ResourceManagerServiceImpl.create(ResourceManagerFactory<?> resourceManagerFactory, Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
ResourceManagerProcessContext	ResourceManagerFactory.createResourceManagerProcessContext(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
static ResourceManagerRuntimeServices	ResourceManagerRuntimeServices.fromConfiguration(ResourceManagerRuntimeServicesConfiguration configuration, HighAvailabilityServices highAvailabilityServices, ScheduledExecutor scheduledExecutor, SlotManagerMetricGroup slotManagerMetricGroup)

Constructors in org.apache.flink.runtime.resourcemanager with parameters of type HighAvailabilityServices

Constructor and Description
DefaultJobLeaderIdService(HighAvailabilityServices highAvailabilityServices, ScheduledExecutor scheduledExecutor, Time jobTimeout)
ResourceManagerProcessContext(Configuration rmConfig, ResourceID resourceId, ResourceManagerRuntimeServicesConfiguration rmRuntimeServicesConfig, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)

Uses of HighAvailabilityServices in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor with parameters of type HighAvailabilityServices

Modifier and Type	Method and Description
TaskManagerRunner.TaskExecutorService	TaskManagerRunner.TaskExecutorServiceFactory.createTaskExecutor(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)
static TaskManagerRunner.TaskExecutorService	TaskManagerRunner.createTaskExecutorService(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)
void	JobLeaderService.start(String initialOwnerAddress, RpcService initialRpcService, HighAvailabilityServices initialHighAvailabilityServices, JobLeaderListener initialJobLeaderListener) Start the job leader service with the given services.
void	DefaultJobLeaderService.start(String initialOwnerAddress, RpcService initialRpcService, HighAvailabilityServices initialHighAvailabilityServices, JobLeaderListener initialJobLeaderListener)
static TaskExecutor	TaskManagerRunner.startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, TaskExecutorBlobService taskExecutorBlobService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)

Constructors in org.apache.flink.runtime.taskexecutor with parameters of type HighAvailabilityServices

Constructor and Description

TaskExecutor(RpcService rpcService, TaskManagerConfiguration taskManagerConfiguration, HighAvailabilityServices haServices, TaskManagerServices taskExecutorServices, ExternalResourceInfoProvider externalResourceInfoProvider, HeartbeatServices heartbeatServices, TaskManagerMetricGroup taskManagerMetricGroup, String metricQueryServiceAddress, TaskExecutorBlobService taskExecutorBlobService, FatalErrorHandler fatalErrorHandler, TaskExecutorPartitionTracker partitionTracker)