org.apache.flink.runtime.entrypoint

Class ClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

All Implemented Interfaces:

AutoCloseable, FatalErrorHandler, AutoCloseableAsync

Direct Known Subclasses:

JobClusterEntrypoint, SessionClusterEntrypoint

public abstract class ClusterEntrypoint
extends Object
implements AutoCloseableAsync, FatalErrorHandler

Base class for the Flink cluster entry points.

Specialization of this class can be used for the session mode and the per-job mode

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClusterEntrypoint.ExecutionMode Execution mode of the MiniDispatcher.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	EXECUTION_MODE
protected static org.slf4j.Logger	LOG
protected static int	RUNTIME_FAILURE_RETURN_CODE
protected static int	STARTUP_FAILURE_RETURN_CODE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClusterEntrypoint(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
protected abstract DispatcherResourceManagerComponentFactory<?>	createDispatcherResourceManagerComponentFactory(Configuration configuration)
protected HighAvailabilityServices	createHaServices(Configuration configuration, Executor executor)
protected HeartbeatServices	createHeartbeatServices(Configuration configuration)
protected MetricRegistryImpl	createMetricRegistry(Configuration configuration)
protected abstract ArchivedExecutionGraphStore	createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
protected String	getRPCPortRange(Configuration configuration) Returns the port range for the common RpcService.
CompletableFuture<ApplicationStatus>	getTerminationFuture()
protected void	initializeServices(Configuration configuration)
protected SecurityContext	installSecurityContext(Configuration configuration)
protected static Configuration	loadConfiguration(EntrypointClusterConfiguration entrypointClusterConfiguration)
void	onFatalError(Throwable exception) Being called when a fatal error occurs.
protected static EntrypointClusterConfiguration	parseArguments(String[] args)
static void	runClusterEntrypoint(ClusterEntrypoint clusterEntrypoint)
void	startCluster()
protected CompletableFuture<Void>	stopClusterServices(boolean cleanupHaData)

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

Field Detail

EXECUTION_MODE

public static final ConfigOption<String> EXECUTION_MODE

LOG

protected static final org.slf4j.Logger LOG

STARTUP_FAILURE_RETURN_CODE

protected static final int STARTUP_FAILURE_RETURN_CODE

See Also:

Constant Field Values

RUNTIME_FAILURE_RETURN_CODE

protected static final int RUNTIME_FAILURE_RETURN_CODE

See Also:

Constant Field Values

Constructor Detail

ClusterEntrypoint

protected ClusterEntrypoint(Configuration configuration)

Method Detail

getTerminationFuture

public CompletableFuture<ApplicationStatus> getTerminationFuture()

startCluster

public void startCluster()
                  throws ClusterEntrypointException

Throws:

ClusterEntrypointException

installSecurityContext

protected SecurityContext installSecurityContext(Configuration configuration)
                                          throws Exception

Throws:

Exception

initializeServices

protected void initializeServices(Configuration configuration)
                           throws Exception

Throws:

Exception

getRPCPortRange

protected String getRPCPortRange(Configuration configuration)

Returns the port range for the common RpcService.

Parameters:

configuration - to extract the port range from

Returns:

Port range for the common RpcService

createHaServices

protected HighAvailabilityServices createHaServices(Configuration configuration,
                                                    Executor executor)
                                             throws Exception

Throws:

Exception

createHeartbeatServices

protected HeartbeatServices createHeartbeatServices(Configuration configuration)

createMetricRegistry

protected MetricRegistryImpl createMetricRegistry(Configuration configuration)

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed

stopClusterServices

protected CompletableFuture<Void> stopClusterServices(boolean cleanupHaData)

onFatalError

public void onFatalError(Throwable exception)

Description copied from interface: FatalErrorHandler

Being called when a fatal error occurs.

IMPORTANT: This call should never be blocking since it might be called from within the main thread of an RpcEndpoint.

Specified by:

onFatalError in interface FatalErrorHandler

Parameters:

exception - cause

createDispatcherResourceManagerComponentFactory

protected abstract DispatcherResourceManagerComponentFactory<?> createDispatcherResourceManagerComponentFactory(Configuration configuration)

createSerializableExecutionGraphStore

protected abstract ArchivedExecutionGraphStore createSerializableExecutionGraphStore(Configuration configuration,
                                                                                     ScheduledExecutor scheduledExecutor)
                                                                              throws IOException

Throws:

IOException

parseArguments

protected static EntrypointClusterConfiguration parseArguments(String[] args)
                                                        throws FlinkParseException

Throws:

FlinkParseException

loadConfiguration

protected static Configuration loadConfiguration(EntrypointClusterConfiguration entrypointClusterConfiguration)

runClusterEntrypoint

public static void runClusterEntrypoint(ClusterEntrypoint clusterEntrypoint)