Package org.apache.flink.yarn

Class YarnResourceManagerDriver

java.lang.Object

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

org.apache.flink.yarn.YarnResourceManagerDriver

All Implemented Interfaces:

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

public class YarnResourceManagerDriver
extends org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver<YarnWorkerNode>

Implementation of ResourceManagerDriver for Yarn deployment.

Field Summary

Fields inherited from class org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver

flinkClientConfig, flinkConfig, log

Constructor Summary

Constructors

Constructor	Description
YarnResourceManagerDriver(org.apache.flink.configuration.Configuration flinkConfig, YarnResourceManagerDriverConfiguration configuration, YarnResourceManagerClientFactory yarnResourceManagerClientFactory, YarnNodeManagerClientFactory yarnNodeManagerClientFactory)

Method Summary

Modifier and Type	Method	Description
void	deregisterApplication(org.apache.flink.runtime.clusterframework.ApplicationStatus finalStatus, String optionalDiagnostics)
static String	getContainerCompletedCause(org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus)
protected void	initializeInternal()
void	releaseResource(YarnWorkerNode workerNode)
CompletableFuture<YarnWorkerNode>	requestResource(org.apache.flink.runtime.clusterframework.TaskExecutorProcessSpec taskExecutorProcessSpec)
void	terminate()

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

getBlockedNodeRetriever, getIoExecutor, getMainThreadExecutor, getResourceEventHandler, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnResourceManagerDriver

public YarnResourceManagerDriver(org.apache.flink.configuration.Configuration flinkConfig,
                                 YarnResourceManagerDriverConfiguration configuration,
                                 YarnResourceManagerClientFactory yarnResourceManagerClientFactory,
                                 YarnNodeManagerClientFactory yarnNodeManagerClientFactory)

Method Detail

initializeInternal

protected void initializeInternal()
                           throws Exception

Specified by:

initializeInternal in class org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver<YarnWorkerNode>

Throws:

Exception

terminate

public void terminate()
               throws Exception

Throws:

Exception

deregisterApplication

public void deregisterApplication(org.apache.flink.runtime.clusterframework.ApplicationStatus finalStatus,
                                  @Nullable
                                  String optionalDiagnostics)

requestResource

public CompletableFuture<YarnWorkerNode> requestResource(org.apache.flink.runtime.clusterframework.TaskExecutorProcessSpec taskExecutorProcessSpec)

releaseResource

public void releaseResource(YarnWorkerNode workerNode)

getContainerCompletedCause

public static String getContainerCompletedCause(org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus)