org.apache.flink.yarn.executors

Class YarnJobClusterExecutor

java.lang.Object

org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,YarnClusterClientFactory>

org.apache.flink.yarn.executors.YarnJobClusterExecutor

All Implemented Interfaces:

PipelineExecutor

Deprecated.

@Internal
 @Deprecated
public class YarnJobClusterExecutor
extends AbstractJobClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,YarnClusterClientFactory>

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 Summary

Fields

Modifier and Type	Field and Description
static String	NAME Deprecated.

Constructor Summary

Constructors

Constructor and Description
YarnJobClusterExecutor() Deprecated.

Method Summary

Methods inherited from class org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor

execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NAME

public static final String NAME

Deprecated.

Constructor Detail

YarnJobClusterExecutor

public YarnJobClusterExecutor()

Deprecated.