YarnSessionClusterExecutor (Flink : Yarn 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,YarnClusterClientFactory>
- - org.apache.flink.yarn.executors.YarnSessionClusterExecutor

All Implemented Interfaces:

org.apache.flink.core.execution.CacheSupportedPipelineExecutor, org.apache.flink.core.execution.PipelineExecutor
```
@Internal
public class YarnSessionClusterExecutor
extends org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,YarnClusterClientFactory>
```
The PipelineExecutor to be used when executing a job on an already running cluster.

- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  static String NAME
- Constructor Summary
  
  Constructors
  Constructor Description
  
  YarnSessionClusterExecutor()
- Method Summary
  - Methods inherited from class org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor
    execute, invalidateClusterDataset, listCompletedClusterDatasetIds
  - 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
```

Constructor Detail
- YarnSessionClusterExecutor
```
public YarnSessionClusterExecutor()
```