Package org.apache.flink.runtime.resourcemanager.active

Class ActiveResourceManagerFactory<WorkerType extends ResourceIDRetrievable>

java.lang.Object

org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<WorkerType>

org.apache.flink.runtime.resourcemanager.active.ActiveResourceManagerFactory<WorkerType>

Direct Known Subclasses:

KubernetesResourceManagerFactory, YarnResourceManagerFactory

public abstract class ActiveResourceManagerFactory<WorkerType extends ResourceIDRetrievable>
extends ResourceManagerFactory<WorkerType>

Factory class for creating ActiveResourceManager with various implementations of ResourceManagerDriver.

Field Summary

Fields inherited from class org.apache.flink.runtime.resourcemanager.ResourceManagerFactory

log

Constructor Summary

Constructors

Constructor	Description
ActiveResourceManagerFactory()

Method Summary

Modifier and Type	Method	Description
ResourceManager<WorkerType>	createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
protected abstract ResourceManagerDriver<WorkerType>	createResourceManagerDriver(Configuration configuration, String webInterfaceUrl, String rpcAddress)
static ThresholdMeter	createStartWorkerFailureRater(Configuration configuration)
protected Configuration	getEffectiveConfigurationForResourceManager(Configuration configuration)	Configuration changes in this method will be visible to only ResourceManager.

Methods inherited from class org.apache.flink.runtime.resourcemanager.ResourceManagerFactory

createResourceManager, createResourceManagerProcessContext, createResourceManagerRuntimeServicesConfiguration, supportMultiLeaderSession

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveResourceManagerFactory

public ActiveResourceManagerFactory()

Method Detail

getEffectiveConfigurationForResourceManager

protected Configuration getEffectiveConfigurationForResourceManager(Configuration configuration)

Description copied from class: ResourceManagerFactory

Configuration changes in this method will be visible to only ResourceManager.

Overrides:

getEffectiveConfigurationForResourceManager in class ResourceManagerFactory<WorkerType extends ResourceIDRetrievable>

createResourceManager

public ResourceManager<WorkerType> createResourceManager(Configuration configuration,
                                                         ResourceID resourceId,
                                                         RpcService rpcService,
                                                         UUID leaderSessionId,
                                                         HeartbeatServices heartbeatServices,
                                                         DelegationTokenManager delegationTokenManager,
                                                         FatalErrorHandler fatalErrorHandler,
                                                         ClusterInformation clusterInformation,
                                                         @Nullable
                                                         String webInterfaceUrl,
                                                         ResourceManagerMetricGroup resourceManagerMetricGroup,
                                                         ResourceManagerRuntimeServices resourceManagerRuntimeServices,
                                                         Executor ioExecutor)
                                                  throws Exception

Specified by:

createResourceManager in class ResourceManagerFactory<WorkerType extends ResourceIDRetrievable>

Throws:

Exception

createResourceManagerDriver

protected abstract ResourceManagerDriver<WorkerType> createResourceManagerDriver(Configuration configuration,
                                                                                 @Nullable
                                                                                 String webInterfaceUrl,
                                                                                 String rpcAddress)
                                                                          throws Exception

Throws:

Exception

createStartWorkerFailureRater

public static ThresholdMeter createStartWorkerFailureRater(Configuration configuration)