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 and Description
ActiveResourceManagerFactory()

Method Summary

Modifier and Type	Method and 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.
protected Configuration	getEffectiveConfigurationForResourceManagerAndRuntimeServices(Configuration configuration) Configuration changes in this method will be visible to both ResourceManager and ResourceManagerRuntimeServices.

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

getEffectiveConfigurationForResourceManagerAndRuntimeServices

protected Configuration getEffectiveConfigurationForResourceManagerAndRuntimeServices(Configuration configuration)

Description copied from class: ResourceManagerFactory

Configuration changes in this method will be visible to both ResourceManager and ResourceManagerRuntimeServices. This can be overwritten by ResourceManagerFactory.getEffectiveConfigurationForResourceManager(org.apache.flink.configuration.Configuration).

Overrides:

getEffectiveConfigurationForResourceManagerAndRuntimeServices in class ResourceManagerFactory<WorkerType extends ResourceIDRetrievable>

getEffectiveConfigurationForResourceManager

protected Configuration getEffectiveConfigurationForResourceManager(Configuration configuration)

Description copied from class: ResourceManagerFactory

Configuration changes in this method will be visible to only ResourceManager. This can overwrite ResourceManagerFactory.getEffectiveConfigurationForResourceManagerAndRuntimeServices(org.apache.flink.configuration.Configuration).

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)