Modifier and Type | Class and Description |
---|---|
static class |
ContainerLaunch.ShellScriptBuilder |
Modifier and Type | Field and Description |
---|---|
protected AtomicBoolean |
completed |
protected Container |
container |
static String |
CONTAINER_SCRIPT |
protected org.apache.hadoop.yarn.event.Dispatcher |
dispatcher |
protected ContainerExecutor |
exec |
static String |
FINAL_CONTAINER_TOKENS_FILE |
protected org.apache.hadoop.fs.Path |
pidFilePath |
protected AtomicBoolean |
shouldLaunchContainer |
Constructor and Description |
---|
ContainerLaunch(Context context,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
Application app,
Container container,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
Modifier and Type | Method and Description |
---|---|
Integer |
call() |
void |
cleanupContainer()
Cleanup the container.
|
static String |
expandEnvironment(String var,
org.apache.hadoop.fs.Path containerLogDir) |
static String |
getExitCodeFile(String pidFile) |
protected String |
getPidFileSubpath(String appIdStr,
String containerIdStr) |
static String |
getRelativeContainerLogDir(String appIdStr,
String containerIdStr) |
void |
sanitizeEnv(Map<String,String> environment,
org.apache.hadoop.fs.Path pwd,
List<org.apache.hadoop.fs.Path> appDirs,
List<String> containerLogDirs,
Map<org.apache.hadoop.fs.Path,List<String>> resources,
org.apache.hadoop.fs.Path nmPrivateClasspathJarDir) |
public static final String CONTAINER_SCRIPT
public static final String FINAL_CONTAINER_TOKENS_FILE
protected final org.apache.hadoop.yarn.event.Dispatcher dispatcher
protected final ContainerExecutor exec
protected final Container container
protected AtomicBoolean shouldLaunchContainer
protected AtomicBoolean completed
protected org.apache.hadoop.fs.Path pidFilePath
public ContainerLaunch(Context context, org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.yarn.event.Dispatcher dispatcher, ContainerExecutor exec, Application app, Container container, LocalDirsHandlerService dirsHandler, ContainerManagerImpl containerManager)
public static String expandEnvironment(String var, org.apache.hadoop.fs.Path containerLogDir)
public void cleanupContainer() throws IOException
IOException
public static String getRelativeContainerLogDir(String appIdStr, String containerIdStr)
public void sanitizeEnv(Map<String,String> environment, org.apache.hadoop.fs.Path pwd, List<org.apache.hadoop.fs.Path> appDirs, List<String> containerLogDirs, Map<org.apache.hadoop.fs.Path,List<String>> resources, org.apache.hadoop.fs.Path nmPrivateClasspathJarDir) throws IOException
IOException
Copyright © 2016 Apache Software Foundation. All Rights Reserved.