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:

AutoCloseable, org.apache.flink.runtime.rpc.FatalErrorHandler, org.apache.flink.util.AutoCloseableAsync

public class YarnJobClusterEntrypoint
extends org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

Entry point for Yarn per-job clusters.

Nested Class Summary

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

org.apache.flink.runtime.entrypoint.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
YarnJobClusterEntrypoint(org.apache.flink.configuration.Configuration configuration, String workingDirectory)

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponentFactory<?>	createDispatcherResourceManagerComponentFactory(org.apache.flink.configuration.Configuration configuration)
protected String	getRPCPortRange(org.apache.flink.configuration.Configuration configuration)
protected org.apache.flink.runtime.security.SecurityContext	installSecurityContext(org.apache.flink.configuration.Configuration configuration)
static void	main(String[] args)

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

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

YarnJobClusterEntrypoint

public YarnJobClusterEntrypoint(org.apache.flink.configuration.Configuration configuration,
                                String workingDirectory)

Method Detail

installSecurityContext

protected org.apache.flink.runtime.security.SecurityContext installSecurityContext(org.apache.flink.configuration.Configuration configuration)
                                                                            throws Exception

Overrides:

installSecurityContext in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

Throws:

Exception

getRPCPortRange

protected String getRPCPortRange(org.apache.flink.configuration.Configuration configuration)

Overrides:

getRPCPortRange in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

createDispatcherResourceManagerComponentFactory

protected org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponentFactory<?> createDispatcherResourceManagerComponentFactory(org.apache.flink.configuration.Configuration configuration)

Specified by:

createDispatcherResourceManagerComponentFactory in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

main

public static void main(String[] args)