org.apache.flink.yarn.entrypoint

Class YarnJobClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

All Implemented Interfaces:

FatalErrorHandler

public class YarnJobClusterEntrypoint
extends JobClusterEntrypoint

Entry point for Yarn per-job clusters.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

ClusterEntrypoint.ExecutionMode

Field Summary

Fields

Modifier and Type	Field and Description
static String	JOB_GRAPH_FILE_PATH The job graph file path.

Fields inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
YarnJobClusterEntrypoint(Configuration configuration, String workingDirectory)

Method Summary

Modifier and Type	Method and Description
protected ResourceManager<?>	createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)
protected String	getRPCPortRange(Configuration configuration) Returns the port range for the common RpcService.
protected SecurityContext	installSecurityContext(Configuration configuration)
static void	main(String[] args)
protected void	registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture)
protected JobGraph	retrieveJobGraph(Configuration configuration)

Methods inherited from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

createDispatcher, createRestEndpoint, createSerializableExecutionGraphStore

Methods inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runCluster, shutDownAndTerminate, startCluster, startClusterComponents, stopClusterComponents, stopClusterServices

Methods inherited from class java.lang.Object

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

Field Detail

JOB_GRAPH_FILE_PATH

public static final String JOB_GRAPH_FILE_PATH

The job graph file path.

See Also:

Constant Field Values

Constructor Detail

YarnJobClusterEntrypoint

public YarnJobClusterEntrypoint(Configuration configuration,
                                String workingDirectory)

Method Detail

installSecurityContext

protected SecurityContext installSecurityContext(Configuration configuration)
                                          throws Exception

Overrides:

installSecurityContext in class ClusterEntrypoint

Throws:

Exception

getRPCPortRange

protected String getRPCPortRange(Configuration configuration)

Description copied from class: ClusterEntrypoint

Returns the port range for the common RpcService.

Overrides:

getRPCPortRange in class ClusterEntrypoint

Parameters:

configuration - to extract the port range from

Returns:

Port range for the common RpcService

createResourceManager

protected ResourceManager<?> createResourceManager(Configuration configuration,
                                                   ResourceID resourceId,
                                                   RpcService rpcService,
                                                   HighAvailabilityServices highAvailabilityServices,
                                                   HeartbeatServices heartbeatServices,
                                                   MetricRegistry metricRegistry,
                                                   FatalErrorHandler fatalErrorHandler,
                                                   ClusterInformation clusterInformation,
                                                   @Nullable
                                                   String webInterfaceUrl,
                                                   JobManagerMetricGroup jobManagerMetricGroup)
                                            throws Exception

Specified by:

createResourceManager in class ClusterEntrypoint

Throws:

Exception

retrieveJobGraph

protected JobGraph retrieveJobGraph(Configuration configuration)
                             throws FlinkException

Specified by:

retrieveJobGraph in class JobClusterEntrypoint

Throws:

FlinkException

registerShutdownActions

protected void registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture)

Specified by:

registerShutdownActions in class JobClusterEntrypoint

main

public static void main(String[] args)