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 org.apache.flink.runtime.resourcemanager.active.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 org.apache.flink.runtime.resourcemanager.active.ResourceManagerDriver<KubernetesWorkerNode>	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 KubernetesResourceManagerFactory	getInstance()

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

Specified by:

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

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<KubernetesWorkerNode>

Throws:

org.apache.flink.util.ConfigurationException