Package org.apache.flink.yarn.entrypoint

Class YarnJobClusterEntrypoint

  • All Implemented Interfaces:
    AutoCloseable, org.apache.flink.runtime.rpc.FatalErrorHandler, org.apache.flink.util.AutoCloseableAsync
    @Deprecated
public class YarnJobClusterEntrypoint
extends org.apache.flink.runtime.entrypoint.JobClusterEntrypoint
    Deprecated.
    Per-mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.
    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, 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 
      Constructor Description
      YarnJobClusterEntrypoint​(org.apache.flink.configuration.Configuration configuration)
      Deprecated.
       

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      protected org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory​(org.apache.flink.configuration.Configuration configuration)
      Deprecated.
       
      protected String getRPCPortRange​(org.apache.flink.configuration.Configuration configuration)
      Deprecated.
       
      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, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices, supportsReactiveMode

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

        close

    • Constructor Detail

      • YarnJobClusterEntrypoint

        public YarnJobClusterEntrypoint​(org.apache.flink.configuration.Configuration configuration)
        Deprecated.

    • Method Detail

      • getRPCPortRange

        protected String getRPCPortRange​(org.apache.flink.configuration.Configuration configuration)
        Deprecated.
        Overrides:
        getRPCPortRange in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

      • createDispatcherResourceManagerComponentFactory

        protected org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory​(org.apache.flink.configuration.Configuration configuration)
                                                                                                                                                  throws IOException
        Deprecated.
        Specified by:
        createDispatcherResourceManagerComponentFactory in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint
        Throws:
        IOException

      • main

        public static void main​(String[] args)
        Deprecated.