org.apache.flink.container.entrypoint

Class StandaloneApplicationClusterEntryPoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

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

org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint

All Implemented Interfaces:

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

@Internal
public final class StandaloneApplicationClusterEntryPoint
extends org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint

An ApplicationClusterEntryPoint which is started with a job in a predefined location.

Nested Class Summary

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

org.apache.flink.runtime.entrypoint.ClusterEntrypoint.ExecutionMode, org.apache.flink.runtime.entrypoint.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
static void	main(String[] args)
protected boolean	supportsReactiveMode()

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, getRPCPortRange, getTerminationFuture, initializeServices, installSecurityContext, 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

Method Detail

main

public static void main(String[] args)

supportsReactiveMode

protected boolean supportsReactiveMode()

Overrides:

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