Package | Description |
---|---|
org.apache.flink.yarn | |
org.apache.flink.yarn.cli |
Modifier and Type | Class and Description |
---|---|
class |
YarnClusterDescriptor
Default implementation of
AbstractYarnClusterDescriptor which starts an YarnApplicationMasterRunner . |
class |
YarnClusterDescriptorV2
Implementation of
AbstractYarnClusterDescriptor which is used to start the new application master for a job under flip-6. |
Modifier and Type | Method and Description |
---|---|
protected YarnClusterClient |
AbstractYarnClusterDescriptor.createYarnClusterClient(AbstractYarnClusterDescriptor descriptor,
int numberTaskManagers,
int slotsPerTaskManager,
org.apache.hadoop.yarn.client.api.YarnClient yarnClient,
org.apache.hadoop.yarn.api.records.ApplicationReport report,
Configuration flinkConfiguration,
boolean perJobCluster)
Creates a YarnClusterClient; may be overriden in tests.
|
Constructor and Description |
---|
YarnClusterClient(AbstractYarnClusterDescriptor clusterDescriptor,
int numberTaskManagers,
int slotsPerTaskManager,
org.apache.hadoop.yarn.client.api.YarnClient yarnClient,
org.apache.hadoop.yarn.api.records.ApplicationReport appReport,
Configuration flinkConfig,
boolean newlyCreatedCluster)
Create a new Flink on YARN cluster.
|
YarnClusterClientV2(AbstractYarnClusterDescriptor clusterDescriptor,
Configuration flinkConfig)
Create a client to communicate with YARN cluster.
|
Modifier and Type | Method and Description |
---|---|
AbstractYarnClusterDescriptor |
FlinkYarnSessionCli.createDescriptor(Configuration configuration,
String configurationDirectory,
String defaultApplicationName,
org.apache.commons.cli.CommandLine cmd) |
protected AbstractYarnClusterDescriptor |
FlinkYarnSessionCli.getClusterDescriptor(Configuration configuration,
String configurationDirectory,
boolean flip6) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.