org.apache.flink.yarn

类 Utils

java.lang.Object

org.apache.flink.yarn.Utils

public final class Utils
extends Object

Utility class that provides helper methods to work with Apache Hadoop YARN.

字段概要

字段

限定符和类型	字段和说明
static String	KEYTAB_FILE_NAME Keytab file name populated in YARN container.
static String	KRB5_FILE_NAME KRB5 file name populated in YARN container for secure IT run.
static int	REMOTE_RESOURCES_FETCH_NUM_RETRY Number of total retries to fetch the remote resources after uploaded in case of FileNotFoundException.
static int	REMOTE_RESOURCES_FETCH_WAIT_IN_MILLI Time to wait in milliseconds between each remote resources fetch in case of FileNotFoundException.
static String	YARN_SITE_FILE_NAME Yarn site xml file name populated in YARN container for secure IT run.

方法概要

限定符和类型	方法和说明
static void	addToEnvironment(Map<String,String> environment, String variable, String value) Copied method from org.apache.hadoop.yarn.util.Apps.
static void	deleteApplicationFiles(Map<String,String> env) Deletes the YARN application files, e.g., Flink binaries, libraries, etc., from the remote filesystem.
static void	setTokensFor(org.apache.hadoop.yarn.api.records.ContainerLaunchContext amContainer, List<org.apache.hadoop.fs.Path> paths, org.apache.hadoop.conf.Configuration conf)
static void	setupYarnClassPath(org.apache.hadoop.conf.Configuration conf, Map<String,String> appMasterEnv)

从类继承的方法 java.lang.Object

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

字段详细资料

KEYTAB_FILE_NAME

public static final String KEYTAB_FILE_NAME

Keytab file name populated in YARN container.

另请参阅:

常量字段值

KRB5_FILE_NAME

public static final String KRB5_FILE_NAME

KRB5 file name populated in YARN container for secure IT run.

另请参阅:

常量字段值

YARN_SITE_FILE_NAME

public static final String YARN_SITE_FILE_NAME

Yarn site xml file name populated in YARN container for secure IT run.

另请参阅:

常量字段值

REMOTE_RESOURCES_FETCH_NUM_RETRY

public static final int REMOTE_RESOURCES_FETCH_NUM_RETRY

Number of total retries to fetch the remote resources after uploaded in case of FileNotFoundException.

另请参阅:

常量字段值

REMOTE_RESOURCES_FETCH_WAIT_IN_MILLI

public static final int REMOTE_RESOURCES_FETCH_WAIT_IN_MILLI

Time to wait in milliseconds between each remote resources fetch in case of FileNotFoundException.

另请参阅:

常量字段值

方法详细资料

setupYarnClassPath

public static void setupYarnClassPath(org.apache.hadoop.conf.Configuration conf,
                                      Map<String,String> appMasterEnv)

deleteApplicationFiles

public static void deleteApplicationFiles(Map<String,String> env)

Deletes the YARN application files, e.g., Flink binaries, libraries, etc., from the remote filesystem.

参数:

env - The environment variables.

setTokensFor

public static void setTokensFor(org.apache.hadoop.yarn.api.records.ContainerLaunchContext amContainer,
                                List<org.apache.hadoop.fs.Path> paths,
                                org.apache.hadoop.conf.Configuration conf)
                         throws IOException

抛出:

IOException

addToEnvironment

public static void addToEnvironment(Map<String,String> environment,
                                    String variable,
                                    String value)

Copied method from org.apache.hadoop.yarn.util.Apps. It was broken by YARN-1824 (2.4.0) and fixed for 2.4.1 by https://issues.apache.org/jira/browse/YARN-1931