Package org.apache.flink.kubernetes.entrypoint

Class KubernetesResourceManagerFactory

java.lang.Object

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

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

org.apache.flink.kubernetes.entrypoint.KubernetesResourceManagerFactory

public class KubernetesResourceManagerFactory
extends ActiveResourceManagerFactory<KubernetesWorkerNode>

ActiveResourceManagerFactory implementation which creates ActiveResourceManager with KubernetesResourceManagerDriver.

Field Summary

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

log

Method Summary

Modifier and Type	Method	Description
protected ResourceManagerDriver<KubernetesWorkerNode>	createResourceManagerDriver(Configuration configuration, String webInterfaceUrl, String rpcAddress)
protected ResourceManagerRuntimeServicesConfiguration	createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
static KubernetesResourceManagerFactory	getInstance()

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

createResourceManager, createStartWorkerFailureRater, getEffectiveConfigurationForResourceManager

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

createResourceManager, createResourceManagerProcessContext, supportMultiLeaderSession

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static KubernetesResourceManagerFactory getInstance()

createResourceManagerDriver

protected ResourceManagerDriver<KubernetesWorkerNode> createResourceManagerDriver(Configuration configuration,
                                                                                  @Nullable
                                                                                  String webInterfaceUrl,
                                                                                  String rpcAddress)

Specified by:

createResourceManagerDriver in class ActiveResourceManagerFactory<KubernetesWorkerNode>

createResourceManagerRuntimeServicesConfiguration

protected ResourceManagerRuntimeServicesConfiguration createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
                                                                                                 throws ConfigurationException

Specified by:

createResourceManagerRuntimeServicesConfiguration in class ResourceManagerFactory<KubernetesWorkerNode>

Throws:

ConfigurationException