Package org.apache.flink.yarn.entrypoint

Class YarnEntrypointUtils

java.lang.Object

org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

public class YarnEntrypointUtils
extends Object

This class contains utility methods for the YarnSessionClusterEntrypoint and YarnJobClusterEntrypoint.

Constructor Summary

Constructors

Constructor	Description
YarnEntrypointUtils()

Method Summary

Modifier and Type	Method	Description
static Optional<File>	getUsrLibDir(org.apache.flink.configuration.Configuration configuration)
static org.apache.flink.configuration.Configuration	loadConfiguration(String workingDirectory, org.apache.flink.configuration.Configuration dynamicParameters, Map<String,String> env)
static void	logYarnEnvironmentInformation(Map<String,String> env, org.slf4j.Logger log)

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnEntrypointUtils

public YarnEntrypointUtils()

Method Detail

loadConfiguration

public static org.apache.flink.configuration.Configuration loadConfiguration(String workingDirectory,
                                                                             org.apache.flink.configuration.Configuration dynamicParameters,
                                                                             Map<String,String> env)

logYarnEnvironmentInformation

public static void logYarnEnvironmentInformation(Map<String,String> env,
                                                 org.slf4j.Logger log)
                                          throws IOException

Throws:

IOException

getUsrLibDir

public static Optional<File> getUsrLibDir(org.apache.flink.configuration.Configuration configuration)