org.apache.flink.yarn.entrypoint

Class YarnResourceManagerFactory

java.lang.Object

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

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

org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

public class YarnResourceManagerFactory
extends ActiveResourceManagerFactory<YarnWorkerNode>

ActiveResourceManagerFactory implementation which creates a ActiveResourceManager with YarnResourceManagerDriver.

Field Summary

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

log

Method Summary

Modifier and Type	Method and Description
protected ResourceManagerDriver<YarnWorkerNode>	createResourceManagerDriver(Configuration configuration, String webInterfaceUrl, String rpcAddress)
protected ResourceManagerRuntimeServicesConfiguration	createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
static YarnResourceManagerFactory	getInstance()
boolean	supportMultiLeaderSession() This indicates whether the process should be terminated after losing leadership.

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

createResourceManager, createStartWorkerFailureRater, getEffectiveConfigurationForResourceManager, getEffectiveConfigurationForResourceManagerAndRuntimeServices

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

createResourceManager, createResourceManagerProcessContext

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static YarnResourceManagerFactory getInstance()

createResourceManagerDriver

protected ResourceManagerDriver<YarnWorkerNode> createResourceManagerDriver(Configuration configuration,
                                                                            String webInterfaceUrl,
                                                                            String rpcAddress)

Specified by:

createResourceManagerDriver in class ActiveResourceManagerFactory<YarnWorkerNode>

createResourceManagerRuntimeServicesConfiguration

protected ResourceManagerRuntimeServicesConfiguration createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
                                                                                                 throws ConfigurationException

Specified by:

createResourceManagerRuntimeServicesConfiguration in class ResourceManagerFactory<YarnWorkerNode>

Throws:

ConfigurationException

supportMultiLeaderSession

public boolean supportMultiLeaderSession()

Description copied from class: ResourceManagerFactory

This indicates whether the process should be terminated after losing leadership.

Overrides:

supportMultiLeaderSession in class ResourceManagerFactory<YarnWorkerNode>