Class YarnJobClusterExecutor

  • All Implemented Interfaces:
    org.apache.flink.core.execution.PipelineExecutor

    @Internal
    @Deprecated
    public class YarnJobClusterExecutor
    extends org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,​YarnClusterClientFactory>
    Deprecated.
    The PipelineExecutor to be used when executing a job in isolation. This executor will start a cluster specifically for the job at hand and tear it down when the job is finished either successfully or due to an error.
    • Field Detail

      • NAME

        public static final String NAME
        Deprecated.
    • Constructor Detail

      • YarnJobClusterExecutor

        public YarnJobClusterExecutor()
        Deprecated.