Author: omalley
Date: Fri Mar 4 04:46:40 2011
New Revision: 1077707
URL: http://svn.apache.org/viewvc?rev=1077707&view=rev
Log:
commit ea4f0a651b2f854be7769f88c932c4119fb9b7dd
Author: Devaraj Das <ddas@yahoo-inc.com>
Date: Sun Sep 19 17:24:16 2010 -0700
Fixing a bug in the deletion of logs when they exceed the size
Modified:
hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/JvmManager.java
Modified: hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/JvmManager.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/JvmManager.java?rev=1077707&r1=1077706&r2=1077707&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/JvmManager.java
(original)
+++ hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/JvmManager.java
Fri Mar 4 04:46:40 2011
@@ -191,7 +191,8 @@ class JvmManager {
" exceeded the allowed " +
"log limits " + logdir);
String user = firstTask.getUser();
- String jobLogDir = firstTask.getJobID().toString() + logdir.getName();
+ String jobLogDir = firstTask.getJobID().toString() +
+ Path.SEPARATOR + logdir.getName();
PathDeletionContext item =
new TaskController.DeletionContext(tracker.getTaskController(),
true, user, jobLogDir);
|