| Package | Description |
|---|---|
| org.apache.flink.yarn | |
| org.apache.flink.yarn.cli |
| Modifier and Type | Class and Description |
|---|---|
class |
LegacyYarnClusterDescriptor
Legacy implementation of
AbstractYarnClusterDescriptor which starts an YarnApplicationMasterRunner. |
class |
YarnClusterDescriptor
Implementation of
AbstractYarnClusterDescriptor which is used to start the
application master. |
| Modifier and Type | Method and Description |
|---|---|
protected abstract org.apache.flink.client.program.ClusterClient<org.apache.hadoop.yarn.api.records.ApplicationId> |
AbstractYarnClusterDescriptor.createYarnClusterClient(AbstractYarnClusterDescriptor descriptor,
int numberTaskManagers,
int slotsPerTaskManager,
org.apache.hadoop.yarn.api.records.ApplicationReport report,
org.apache.flink.configuration.Configuration flinkConfiguration,
boolean perJobCluster)
Creates a YarnClusterClient; may be overriden in tests.
|
protected org.apache.flink.client.program.ClusterClient<org.apache.hadoop.yarn.api.records.ApplicationId> |
LegacyYarnClusterDescriptor.createYarnClusterClient(AbstractYarnClusterDescriptor descriptor,
int numberTaskManagers,
int slotsPerTaskManager,
org.apache.hadoop.yarn.api.records.ApplicationReport report,
org.apache.flink.configuration.Configuration flinkConfiguration,
boolean perJobCluster) |
protected org.apache.flink.client.program.ClusterClient<org.apache.hadoop.yarn.api.records.ApplicationId> |
YarnClusterDescriptor.createYarnClusterClient(AbstractYarnClusterDescriptor descriptor,
int numberTaskManagers,
int slotsPerTaskManager,
org.apache.hadoop.yarn.api.records.ApplicationReport report,
org.apache.flink.configuration.Configuration flinkConfiguration,
boolean perJobCluster) |
| Constructor and Description |
|---|
YarnClusterClient(AbstractYarnClusterDescriptor clusterDescriptor,
int numberTaskManagers,
int slotsPerTaskManager,
org.apache.hadoop.yarn.api.records.ApplicationReport appReport,
org.apache.flink.configuration.Configuration flinkConfig,
boolean newlyCreatedCluster)
Create a new Flink on YARN cluster.
|
| Modifier and Type | Method and Description |
|---|---|
AbstractYarnClusterDescriptor |
FlinkYarnSessionCli.createClusterDescriptor(org.apache.commons.cli.CommandLine commandLine) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.