org.apache.flink.yarn.entrypoint

Class YarnSessionClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint

org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

All Implemented Interfaces:

AutoCloseable, FatalErrorHandler, AutoCloseableAsync

public class YarnSessionClusterEntrypoint
extends SessionClusterEntrypoint

Entry point for Yarn session clusters.

Nested Class Summary

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

ClusterEntrypoint.ExecutionMode

Field Summary

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

EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
YarnSessionClusterEntrypoint(Configuration configuration, String workingDirectory)

Method Summary

Modifier and Type	Method and Description
protected DispatcherResourceManagerComponentFactory<?>	createDispatcherResourceManagerComponentFactory(Configuration configuration)
protected String	getRPCPortRange(Configuration configuration) Returns the port range for the common RpcService.
protected SecurityContext	installSecurityContext(Configuration configuration)
static void	main(String[] args)

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

createSerializableExecutionGraphStore

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

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

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

Constructor Detail

YarnSessionClusterEntrypoint

public YarnSessionClusterEntrypoint(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

createDispatcherResourceManagerComponentFactory

protected DispatcherResourceManagerComponentFactory<?> createDispatcherResourceManagerComponentFactory(Configuration configuration)

Specified by:

createDispatcherResourceManagerComponentFactory in class ClusterEntrypoint

main

public static void main(String[] args)