public class YarnClusterDescriptor extends AbstractYarnClusterDescriptor
AbstractYarnClusterDescriptor
which starts an YarnApplicationMasterRunner
.shipFiles
Constructor and Description |
---|
YarnClusterDescriptor(Configuration flinkConfiguration,
String configurationDirectory) |
Modifier and Type | Method and Description |
---|---|
YarnClusterClient |
deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph)
Deploys a per-job cluster with the given job on the cluster.
|
protected String |
getYarnJobClusterEntrypoint() |
protected String |
getYarnSessionClusterEntrypoint()
The class to bootstrap the application master of the Yarn cluster (runs main method).
|
addLibFolderToShipFiles, addShipFiles, createYarnClusterClient, deployInternal, deploySessionCluster, getClusterDescription, getDynamicPropertiesEncoded, getFlinkConfiguration, getYarnClient, getZookeeperNamespace, hasUserJarFiles, isDetachedMode, retrieve, setDetachedMode, setDynamicPropertiesEncoded, setLocalJarPath, setName, setProvidedUserJarFiles, setQueue, setupApplicationMasterContainer, setZookeeperNamespace, startAppMaster, validateClusterResources
public YarnClusterDescriptor(Configuration flinkConfiguration, String configurationDirectory)
protected String getYarnSessionClusterEntrypoint()
AbstractYarnClusterDescriptor
getYarnSessionClusterEntrypoint
in class AbstractYarnClusterDescriptor
protected String getYarnJobClusterEntrypoint()
getYarnJobClusterEntrypoint
in class AbstractYarnClusterDescriptor
public YarnClusterClient deployJobCluster(ClusterSpecification clusterSpecification, JobGraph jobGraph)
ClusterDescriptor
deployJobCluster
in interface ClusterDescriptor<YarnClusterClient>
deployJobCluster
in class AbstractYarnClusterDescriptor
clusterSpecification
- Initial cluster specification with which the Flink cluster is launchedjobGraph
- JobGraph with which the job cluster is startedCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.