Package 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
@Internal @Deprecated public class YarnJobClusterExecutor extends AbstractJobClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,YarnClusterClientFactory>
Deprecated.ThePipelineExecutor
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.
-
-
Constructor Summary
Constructors Constructor Description YarnJobClusterExecutor()
Deprecated.
-
-
-
Field Detail
-
NAME
public static final String NAME
Deprecated.
-
-