public class StandaloneHaServices extends AbstractNonHaServices
HighAvailabilityServices
for the non-high-availability case.
This implementation can be used for testing, and for cluster setups that do not
tolerate failures of the master processes (JobManager, ResourceManager).
This implementation has no dependencies on any external services. It returns a fix pre-configured ResourceManager and JobManager, and stores checkpoints and metadata simply on the heap or on a local file system and therefore in a storage without guarantees.
lock
DEFAULT_JOB_ID, DEFAULT_LEADER_ID
Constructor and Description |
---|
StandaloneHaServices(String resourceManagerAddress,
String jobManagerAddress)
Creates a new services class for the fix pre-defined leaders.
|
Modifier and Type | Method and Description |
---|---|
LeaderElectionService |
getJobManagerLeaderElectionService(JobID jobID)
Gets the leader election service for the given job.
|
LeaderRetrievalService |
getJobManagerLeaderRetriever(JobID jobID)
Gets the leader retriever for the job JobMaster which is responsible for the given job
|
LeaderElectionService |
getResourceManagerLeaderElectionService()
Gets the leader election service for the cluster's resource manager.
|
LeaderRetrievalService |
getResourceManagerLeaderRetriever()
Gets the leader retriever for the cluster's resource manager.
|
checkNotShutdown, close, closeAndCleanupAllData, createBlobStore, getCheckpointRecoveryFactory, getRunningJobsRegistry, getSubmittedJobGraphStore, isShutDown
public LeaderRetrievalService getResourceManagerLeaderRetriever()
HighAvailabilityServices
public LeaderElectionService getResourceManagerLeaderElectionService()
HighAvailabilityServices
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID)
HighAvailabilityServices
jobID
- The identifier of the job.public LeaderElectionService getJobManagerLeaderElectionService(JobID jobID)
HighAvailabilityServices
jobID
- The identifier of the job running the election.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.