Package 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 org.apache.flink.runtime.resourcemanager.active.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	Description
protected org.apache.flink.runtime.resourcemanager.active.ResourceManagerDriver<YarnWorkerNode>	createResourceManagerDriver(org.apache.flink.configuration.Configuration configuration, String webInterfaceUrl, String rpcAddress)
protected org.apache.flink.runtime.resourcemanager.ResourceManagerRuntimeServicesConfiguration	createResourceManagerRuntimeServicesConfiguration(org.apache.flink.configuration.Configuration configuration)
static YarnResourceManagerFactory	getInstance()
boolean	supportMultiLeaderSession()

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 org.apache.flink.runtime.resourcemanager.active.ResourceManagerDriver<YarnWorkerNode> createResourceManagerDriver(org.apache.flink.configuration.Configuration configuration,
                                                                                                                            String webInterfaceUrl,
                                                                                                                            String rpcAddress)

Specified by:

createResourceManagerDriver in class org.apache.flink.runtime.resourcemanager.active.ActiveResourceManagerFactory<YarnWorkerNode>

createResourceManagerRuntimeServicesConfiguration

protected org.apache.flink.runtime.resourcemanager.ResourceManagerRuntimeServicesConfiguration createResourceManagerRuntimeServicesConfiguration(org.apache.flink.configuration.Configuration configuration)
                                                                                                                                          throws org.apache.flink.util.ConfigurationException

Specified by:

createResourceManagerRuntimeServicesConfiguration in class org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<YarnWorkerNode>

Throws:

org.apache.flink.util.ConfigurationException

supportMultiLeaderSession

public boolean supportMultiLeaderSession()

Overrides:

supportMultiLeaderSession in class org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<YarnWorkerNode>