|
@@ -100,7 +100,7 @@ public class ContainerLaunch implements Callable<Integer> {
|
|
String appIdStr = app.toString();
|
|
String appIdStr = app.toString();
|
|
Path containerLogDir =
|
|
Path containerLogDir =
|
|
this.logDirsSelector.getLocalPathForWrite(appIdStr + Path.SEPARATOR
|
|
this.logDirsSelector.getLocalPathForWrite(appIdStr + Path.SEPARATOR
|
|
- + containerIdStr, LocalDirAllocator.SIZE_UNKNOWN, this.conf, false);
|
|
|
|
|
|
+ + containerIdStr, LocalDirAllocator.SIZE_UNKNOWN, this.conf);
|
|
for (String str : command) {
|
|
for (String str : command) {
|
|
// TODO: Should we instead work via symlinks without this grammar?
|
|
// TODO: Should we instead work via symlinks without this grammar?
|
|
newCmds.add(str.replace(ApplicationConstants.LOG_DIR_EXPANSION_VAR,
|
|
newCmds.add(str.replace(ApplicationConstants.LOG_DIR_EXPANSION_VAR,
|
|
@@ -129,9 +129,7 @@ public class ContainerLaunch implements Callable<Integer> {
|
|
lDirAllocator.getLocalPathForWrite(
|
|
lDirAllocator.getLocalPathForWrite(
|
|
ResourceLocalizationService.NM_PRIVATE_DIR + Path.SEPARATOR
|
|
ResourceLocalizationService.NM_PRIVATE_DIR + Path.SEPARATOR
|
|
+ appIdStr + Path.SEPARATOR + containerIdStr
|
|
+ appIdStr + Path.SEPARATOR + containerIdStr
|
|
- + Path.SEPARATOR + CONTAINER_SCRIPT,
|
|
|
|
- LocalDirAllocator.SIZE_UNKNOWN,
|
|
|
|
- this.conf, false);
|
|
|
|
|
|
+ + Path.SEPARATOR + CONTAINER_SCRIPT, this.conf);
|
|
Path nmPrivateTokensPath =
|
|
Path nmPrivateTokensPath =
|
|
lDirAllocator.getLocalPathForWrite(
|
|
lDirAllocator.getLocalPathForWrite(
|
|
ResourceLocalizationService.NM_PRIVATE_DIR
|
|
ResourceLocalizationService.NM_PRIVATE_DIR
|
|
@@ -139,8 +137,7 @@ public class ContainerLaunch implements Callable<Integer> {
|
|
+ containerIdStr
|
|
+ containerIdStr
|
|
+ Path.SEPARATOR
|
|
+ Path.SEPARATOR
|
|
+ String.format(ContainerLocalizer.TOKEN_FILE_NAME_FMT,
|
|
+ String.format(ContainerLocalizer.TOKEN_FILE_NAME_FMT,
|
|
- containerIdStr), LocalDirAllocator.SIZE_UNKNOWN,
|
|
|
|
- this.conf, false);
|
|
|
|
|
|
+ containerIdStr), this.conf);
|
|
DataOutputStream containerScriptOutStream = null;
|
|
DataOutputStream containerScriptOutStream = null;
|
|
DataOutputStream tokensOutStream = null;
|
|
DataOutputStream tokensOutStream = null;
|
|
|
|
|
|
@@ -150,7 +147,7 @@ public class ContainerLaunch implements Callable<Integer> {
|
|
+ Path.SEPARATOR + user + Path.SEPARATOR
|
|
+ Path.SEPARATOR + user + Path.SEPARATOR
|
|
+ ContainerLocalizer.APPCACHE + Path.SEPARATOR + appIdStr
|
|
+ ContainerLocalizer.APPCACHE + Path.SEPARATOR + appIdStr
|
|
+ Path.SEPARATOR + containerIdStr,
|
|
+ Path.SEPARATOR + containerIdStr,
|
|
- LocalDirAllocator.SIZE_UNKNOWN, this.conf, false);
|
|
|
|
|
|
+ LocalDirAllocator.SIZE_UNKNOWN, this.conf);
|
|
try {
|
|
try {
|
|
// /////////// Write out the container-script in the nmPrivate space.
|
|
// /////////// Write out the container-script in the nmPrivate space.
|
|
String[] localDirs =
|
|
String[] localDirs =
|