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, FatalErrorHandler, AutoCloseableAsync

Deprecated.

Per-mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.

@Deprecated
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, 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

Constructor Summary

Constructors

Constructor and Description
YarnJobClusterEntrypoint(Configuration configuration) Deprecated.

Method Summary

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

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

createSerializableExecutionGraphStore

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

cleanupDirectories, 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

Constructor Detail

YarnJobClusterEntrypoint

public YarnJobClusterEntrypoint(Configuration configuration)

Deprecated.

Method Detail

getRPCPortRange

protected String getRPCPortRange(Configuration configuration)

Deprecated.

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 DefaultDispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory(Configuration configuration)
                                                                                                    throws IOException

Deprecated.

Specified by:

createDispatcherResourceManagerComponentFactory in class ClusterEntrypoint

Throws:

IOException

main

public static void main(String[] args)

Deprecated.