Package org.apache.flink.client.deployment.application

Class ApplicationClusterEntryPoint

  • All Implemented Interfaces:
    AutoCloseable, org.apache.flink.runtime.rpc.FatalErrorHandler, org.apache.flink.util.AutoCloseableAsync
    public class ApplicationClusterEntryPoint
extends org.apache.flink.runtime.entrypoint.ClusterEntrypoint
    Base class for cluster entry points targeting executing applications in "Application Mode". The lifecycle of the entry point is bound to that of the specific application being executed, and the main() method of the application is run on the cluster.

    • 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

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected ApplicationClusterEntryPoint​(org.apache.flink.configuration.Configuration configuration, PackagedProgram program, org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<?> resourceManagerFactory)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void cleanupDirectories​(org.apache.flink.runtime.entrypoint.ClusterEntrypoint.ShutdownBehaviour shutdownBehaviour)  
      protected static void configureExecution​(org.apache.flink.configuration.Configuration configuration, PackagedProgram program)  
      protected org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory​(org.apache.flink.configuration.Configuration configuration)  
      protected org.apache.flink.runtime.dispatcher.ExecutionGraphInfoStore createSerializableExecutionGraphStore​(org.apache.flink.configuration.Configuration configuration, org.apache.flink.util.concurrent.ScheduledExecutor scheduledExecutor)  

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

        closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRestPort, getRpcPort, getRPCPortRange, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices, supportsReactiveMode

      • Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

        close

    • Constructor Detail

      • ApplicationClusterEntryPoint

        protected ApplicationClusterEntryPoint​(org.apache.flink.configuration.Configuration configuration,
                                       PackagedProgram program,
                                       org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<?> resourceManagerFactory)

    • Method Detail

      • 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

      • createSerializableExecutionGraphStore

        protected org.apache.flink.runtime.dispatcher.ExecutionGraphInfoStore createSerializableExecutionGraphStore​(org.apache.flink.configuration.Configuration configuration,
                                                                                                            org.apache.flink.util.concurrent.ScheduledExecutor scheduledExecutor)
        Specified by:
        createSerializableExecutionGraphStore in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

      • configureExecution

        protected static void configureExecution​(org.apache.flink.configuration.Configuration configuration,
                                         PackagedProgram program)
                                  throws Exception
        Throws:
        Exception

      • cleanupDirectories

        protected void cleanupDirectories​(org.apache.flink.runtime.entrypoint.ClusterEntrypoint.ShutdownBehaviour shutdownBehaviour)
                           throws IOException
        Overrides:
        cleanupDirectories in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint
        Throws:
        IOException