You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by sh...@apache.org on 2011/04/29 11:13:48 UTC
svn commit: r1097737 - in /hadoop/mapreduce/branches/MR-279: CHANGES.txt
mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryEventHandler.java
Author: sharad
Date: Fri Apr 29 09:13:48 2011
New Revision: 1097737
URL: http://svn.apache.org/viewvc?rev=1097737&view=rev
Log:
Fix file creation in JobHistoryEventHandler.
Modified:
hadoop/mapreduce/branches/MR-279/CHANGES.txt
hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryEventHandler.java
Modified: hadoop/mapreduce/branches/MR-279/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/CHANGES.txt?rev=1097737&r1=1097736&r2=1097737&view=diff
==============================================================================
--- hadoop/mapreduce/branches/MR-279/CHANGES.txt (original)
+++ hadoop/mapreduce/branches/MR-279/CHANGES.txt Fri Apr 29 09:13:48 2011
@@ -3,6 +3,7 @@ Hadoop MapReduce Change Log
Trunk (unreleased changes)
MAPREDUCE-279
+ Fix file creation in JobHistoryEventHandler. (sharad)
Reorient container localization to be per-container rather than
per-application. (cdouglas)
Modified: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryEventHandler.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryEventHandler.java?rev=1097737&r1=1097736&r2=1097737&view=diff
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryEventHandler.java (original)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryEventHandler.java Fri Apr 29 09:13:48 2011
@@ -208,7 +208,7 @@ public class JobHistoryEventHandler exte
if (writer == null) {
try {
FSDataOutputStream out = logDirFc.create(logFile, EnumSet
- .of(CreateFlag.OVERWRITE));
+ .of(CreateFlag.CREATE, CreateFlag.OVERWRITE));
writer = new EventWriter(out);
} catch (IOException ioe) {
LOG.info("Could not create log file for job " + jobName);
@@ -385,7 +385,7 @@ public class JobHistoryEventHandler exte
new FsPermission(HISTORY_DIR_PERMISSION), true);
Path toPath = new Path(statusstoredir, "jobstats");
FSDataOutputStream out = doneDirFc.create(toPath, EnumSet
- .of(CreateFlag.OVERWRITE));
+ .of(CreateFlag.CREATE, CreateFlag.OVERWRITE));
EventWriter writer = new EventWriter(out);
writer.write(event);
writer.close();