public class DefaultContainerExecutor extends ContainerExecutor
ContainerExecutor.DelayedProcessKiller, ContainerExecutor.ExitCode, ContainerExecutor.Signal
TASK_LAUNCH_SCRIPT_PERMISSION
Constructor and Description |
---|
DefaultContainerExecutor() |
Modifier and Type | Method and Description |
---|---|
static boolean |
containerIsAlive(String pid)
Returns true if the process with the specified pid is alive.
|
void |
deleteAsUser(String user,
Path subDir,
Path... baseDirs) |
void |
init()
Run the executor initialization steps.
|
int |
launchContainer(Container container,
Path nmPrivateContainerScriptPath,
Path nmPrivateTokensPath,
String userName,
String appId,
Path containerWorkDir,
List<String> localDirs,
List<String> logDirs)
Launch the container on the node.
|
boolean |
signalContainer(String user,
String pid,
ContainerExecutor.Signal signal) |
void |
startLocalizer(Path nmPrivateContainerTokensPath,
InetSocketAddress nmAddr,
String user,
String appId,
String locId,
List<String> localDirs,
List<String> logDirs)
Prepare the environment for containers in this application to execute.
|
activateContainer, deactivateContainer, getConf, getPidFilePath, getProcessId, getRunCommand, isContainerActive, logOutput, setConf
public void init() throws IOException
ContainerExecutor
init
in class ContainerExecutor
IOException
public void startLocalizer(Path nmPrivateContainerTokensPath, InetSocketAddress nmAddr, String user, String appId, String locId, List<String> localDirs, List<String> logDirs) throws IOException, InterruptedException
ContainerExecutor
startLocalizer
in class ContainerExecutor
nmPrivateContainerTokensPath
- path to localized credentials, rsrc by NMnmAddr
- RPC address to contact NMuser
- user name of application ownerappId
- id of the applicationlocalDirs
- nm-local-dirslogDirs
- nm-log-dirsIOException
- For most application init failuresInterruptedException
- If application init thread is halted by NMpublic int launchContainer(Container container, Path nmPrivateContainerScriptPath, Path nmPrivateTokensPath, String userName, String appId, Path containerWorkDir, List<String> localDirs, List<String> logDirs) throws IOException
ContainerExecutor
launchContainer
in class ContainerExecutor
container
- the container to be launchednmPrivateContainerScriptPath
- the path for launch scriptnmPrivateTokensPath
- the path for tokens for the containeruserName
- the user of the containerappId
- the appId of the containercontainerWorkDir
- the work dir for the containerlocalDirs
- nm-local-dirs to be used for this containerlogDirs
- nm-log-dirs to be used for this containerIOException
public boolean signalContainer(String user, String pid, ContainerExecutor.Signal signal) throws IOException
signalContainer
in class ContainerExecutor
IOException
public static boolean containerIsAlive(String pid) throws IOException
pid
- String pidIOException
public void deleteAsUser(String user, Path subDir, Path... baseDirs) throws IOException, InterruptedException
deleteAsUser
in class ContainerExecutor
IOException
InterruptedException
Copyright © 2013 Apache Software Foundation. All rights reserved.