org.apache.flink.runtime.resourcemanager

Class StandaloneResourceManagerFactory

java.lang.Object

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

org.apache.flink.runtime.resourcemanager.StandaloneResourceManagerFactory

public final class StandaloneResourceManagerFactory
extends ResourceManagerFactory<ResourceID>

ResourceManagerFactory which creates a StandaloneResourceManager.

Field Summary

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

log

Method Summary

Modifier and Type	Method and Description
protected ResourceManager<ResourceID>	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 ResourceManagerRuntimeServicesConfiguration	createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
static Configuration	getConfigurationWithoutMaxSlotNumberIfSet(Configuration configuration) Get the configuration for standalone ResourceManager, overwrite invalid configs.
static StandaloneResourceManagerFactory	getInstance()

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

createResourceManager, createResourceManagerProcessContext, getEffectiveConfigurationForResourceManager, getEffectiveConfigurationForResourceManagerAndRuntimeServices, supportMultiLeaderSession

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static StandaloneResourceManagerFactory getInstance()

createResourceManager

protected ResourceManager<ResourceID> 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)

Specified by:

createResourceManager in class ResourceManagerFactory<ResourceID>

createResourceManagerRuntimeServicesConfiguration

protected ResourceManagerRuntimeServicesConfiguration createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
                                                                                                 throws ConfigurationException

Specified by:

createResourceManagerRuntimeServicesConfiguration in class ResourceManagerFactory<ResourceID>

Throws:

ConfigurationException

getConfigurationWithoutMaxSlotNumberIfSet

@VisibleForTesting
public static Configuration getConfigurationWithoutMaxSlotNumberIfSet(Configuration configuration)

Get the configuration for standalone ResourceManager, overwrite invalid configs.

Parameters:

configuration - configuration object

Returns:

the configuration for standalone ResourceManager