public class YarnEntrypointUtils extends Object
YarnSessionClusterEntrypoint and
YarnJobClusterEntrypoint.| 构造器和说明 |
|---|
YarnEntrypointUtils() |
| 限定符和类型 | 方法和说明 |
|---|---|
static org.apache.flink.runtime.security.SecurityContext |
installSecurityContext(org.apache.flink.configuration.Configuration configuration) |
static org.apache.flink.configuration.Configuration |
loadConfiguration(String workingDirectory,
Map<String,String> env) |
static void |
logYarnEnvironmentInformation(Map<String,String> env,
org.slf4j.Logger log) |
public static org.apache.flink.runtime.security.SecurityContext installSecurityContext(org.apache.flink.configuration.Configuration configuration)
throws Exception
Exceptionpublic static org.apache.flink.configuration.Configuration loadConfiguration(String workingDirectory, Map<String,String> env)
public static void logYarnEnvironmentInformation(Map<String,String> env, org.slf4j.Logger log) throws IOException
IOExceptionCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.