Package org.apache.flink.yarn.cli

Class FallbackYarnSessionCli

java.lang.Object

org.apache.flink.client.cli.AbstractCustomCommandLine

org.apache.flink.yarn.cli.FallbackYarnSessionCli

All Implemented Interfaces:

org.apache.flink.client.cli.CustomCommandLine

@Internal
public class FallbackYarnSessionCli
extends org.apache.flink.client.cli.AbstractCustomCommandLine

A stub Yarn Command Line to throw an exception with the correct message when the HADOOP_CLASSPATH is not set.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.commons.cli.Option	addressOption
protected org.apache.commons.cli.Option	applicationId
protected org.apache.flink.configuration.Configuration	configuration
static String	ID

Fields inherited from class org.apache.flink.client.cli.AbstractCustomCommandLine

zookeeperNamespaceOption

Constructor Summary

Constructors

Constructor	Description
FallbackYarnSessionCli(org.apache.flink.configuration.Configuration configuration)

Method Summary

Modifier and Type	Method	Description
void	addGeneralOptions(org.apache.commons.cli.Options baseOptions)
String	getId()
boolean	isActive(org.apache.commons.cli.CommandLine commandLine)

Methods inherited from class org.apache.flink.client.cli.AbstractCustomCommandLine

addRunOptions, handleCliArgsException, handleError, printUsage, toConfiguration

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.client.cli.CustomCommandLine

parseCommandLineOptions

Field Detail

ID

public static final String ID

See Also:

Constant Field Values

applicationId

protected final org.apache.commons.cli.Option applicationId

addressOption

protected final org.apache.commons.cli.Option addressOption

configuration

protected final org.apache.flink.configuration.Configuration configuration

Constructor Detail

FallbackYarnSessionCli

public FallbackYarnSessionCli(org.apache.flink.configuration.Configuration configuration)

Method Detail

isActive

public boolean isActive(org.apache.commons.cli.CommandLine commandLine)

Specified by:

isActive in interface org.apache.flink.client.cli.CustomCommandLine

addGeneralOptions

public void addGeneralOptions(org.apache.commons.cli.Options baseOptions)

Specified by:

addGeneralOptions in interface org.apache.flink.client.cli.CustomCommandLine

Overrides:

addGeneralOptions in class org.apache.flink.client.cli.AbstractCustomCommandLine

getId

public String getId()