|
@@ -100,7 +100,7 @@ public class TaskLog {
|
|
String strAttemptLogDir = getTaskAttemptLogDir(taskID,
|
|
String strAttemptLogDir = getTaskAttemptLogDir(taskID,
|
|
cleanupSuffix, localDirs);
|
|
cleanupSuffix, localDirs);
|
|
File attemptLogDir = new File(strAttemptLogDir);
|
|
File attemptLogDir = new File(strAttemptLogDir);
|
|
- if (!attemptLogDir.mkdirs()) {
|
|
|
|
|
|
+ if (!attemptLogDir.exists() && !attemptLogDir.mkdirs()) {
|
|
throw new IOException("Creation of " + attemptLogDir + " failed.");
|
|
throw new IOException("Creation of " + attemptLogDir + " failed.");
|
|
}
|
|
}
|
|
String strLinkAttemptLogDir =
|
|
String strLinkAttemptLogDir =
|