org.apache.flink.yarn.entrypoint

Class YarnApplicationClusterEntryPoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint

org.apache.flink.yarn.entrypoint.YarnApplicationClusterEntryPoint

All Implemented Interfaces:

AutoCloseable, FatalErrorHandler, AutoCloseableAsync

@Internal
public final class YarnApplicationClusterEntryPoint
extends ApplicationClusterEntryPoint

An ApplicationClusterEntryPoint for Yarn.

Nested Class Summary

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

ClusterEntrypoint.ExecutionMode, ClusterEntrypoint.ShutdownBehaviour

Field Summary

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

INTERNAL_CLUSTER_EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE

Method Summary

Modifier and Type	Method and Description
protected String	getRPCPortRange(Configuration configuration) Returns the port range for the common RpcService.
static void	main(String[] args)

Methods inherited from class org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint

cleanupDirectories, configureExecution, createDispatcherResourceManagerComponentFactory, createSerializableExecutionGraphStore

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

closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRestPort, getRpcPort, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices, supportsReactiveMode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Method Detail

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

main

public static void main(String[] args)