org.apache.flink.yarn

Class YarnClusterDescriptorV2

java.lang.Object

org.apache.flink.yarn.AbstractYarnClusterDescriptor

org.apache.flink.yarn.YarnClusterDescriptorV2

All Implemented Interfaces:

ClusterDescriptor<YarnClusterClient>

public class YarnClusterDescriptorV2
extends AbstractYarnClusterDescriptor

Implementation of AbstractYarnClusterDescriptor which is used to start the new application master for a job under flip-6. This implementation is now however tricky, since YarnClusterDescriptorV2 is related YarnClusterClientV2, but AbstractYarnClusterDescriptor is related to YarnClusterClient. We should let YarnClusterDescriptorV2 implements ClusterDescriptor<YarnClusterClientV2>. However, in order to use the code in AbstractYarnClusterDescriptor for setting environments and so on, we make YarnClusterDescriptorV2 as now.

Field Summary

Fields inherited from class org.apache.flink.yarn.AbstractYarnClusterDescriptor

shipFiles

Constructor Summary

Constructors

Constructor and Description
YarnClusterDescriptorV2(Configuration flinkConfiguration, String configurationDirectory)

Method Summary

Modifier and Type	Method and Description
protected String	getYarnJobClusterEntrypoint()
protected String	getYarnSessionClusterEntrypoint() The class to bootstrap the application master of the Yarn cluster (runs main method).

Methods inherited from class org.apache.flink.yarn.AbstractYarnClusterDescriptor

addLibFolderToShipFiles, addShipFiles, createYarnClusterClient, deployInternal, deployJobCluster, deploySessionCluster, getClusterDescription, getDynamicPropertiesEncoded, getFlinkConfiguration, getYarnClient, getZookeeperNamespace, hasUserJarFiles, isDetachedMode, retrieve, setDetachedMode, setDynamicPropertiesEncoded, setLocalJarPath, setName, setProvidedUserJarFiles, setQueue, setupApplicationMasterContainer, setZookeeperNamespace, startAppMaster, validateClusterResources

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnClusterDescriptorV2

public YarnClusterDescriptorV2(Configuration flinkConfiguration,
                               String configurationDirectory)

Method Detail

getYarnSessionClusterEntrypoint

protected String getYarnSessionClusterEntrypoint()

Description copied from class: AbstractYarnClusterDescriptor

The class to bootstrap the application master of the Yarn cluster (runs main method).

Specified by:

getYarnSessionClusterEntrypoint in class AbstractYarnClusterDescriptor

getYarnJobClusterEntrypoint

protected String getYarnJobClusterEntrypoint()

Specified by:

getYarnJobClusterEntrypoint in class AbstractYarnClusterDescriptor