org.apache.flink.yarn.entrypoint

Class YarnResourceManagerFactory

java.lang.Object

org.apache.flink.runtime.resourcemanager.ActiveResourceManagerFactory<YarnWorkerNode>

org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

All Implemented Interfaces:

ResourceManagerFactory<YarnWorkerNode>

public class YarnResourceManagerFactory
extends ActiveResourceManagerFactory<YarnWorkerNode>

ResourceManagerFactory implementation which creates a YarnResourceManager.

Method Summary

Modifier and Type	Method and Description
ResourceManager<YarnWorkerNode>	createActiveResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup)
static YarnResourceManagerFactory	getInstance()

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

createActiveResourceManagerConfiguration, createResourceManager

Methods inherited from class java.lang.Object

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

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

generateEndpointIdWithUUID, getEndpointId

Method Detail

getInstance

public static YarnResourceManagerFactory getInstance()

createActiveResourceManager

public ResourceManager<YarnWorkerNode> createActiveResourceManager(Configuration configuration,
                                                                   ResourceID resourceId,
                                                                   RpcService rpcService,
                                                                   HighAvailabilityServices highAvailabilityServices,
                                                                   HeartbeatServices heartbeatServices,
                                                                   FatalErrorHandler fatalErrorHandler,
                                                                   ClusterInformation clusterInformation,
                                                                   @Nullable
                                                                   String webInterfaceUrl,
                                                                   ResourceManagerMetricGroup resourceManagerMetricGroup)
                                                            throws Exception

Specified by:

createActiveResourceManager in class ActiveResourceManagerFactory<YarnWorkerNode>

Throws:

Exception