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 and Description
YarnEntrypointUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.runtime.security.SecurityContext	installSecurityContext(org.apache.flink.configuration.Configuration configuration, String workingDirectory)
static org.apache.flink.configuration.Configuration	loadConfiguration(String workingDirectory, Map<String,String> env, org.slf4j.Logger log)
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

installSecurityContext

public static org.apache.flink.runtime.security.SecurityContext installSecurityContext(org.apache.flink.configuration.Configuration configuration,
                                                                                       String workingDirectory)
                                                                                throws Exception

Throws:

Exception

loadConfiguration

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

logYarnEnvironmentInformation

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

Throws:

IOException