You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by dd...@apache.org on 2008/03/25 11:41:48 UTC

svn commit: r640764 - in /hadoop/core/trunk: CHANGES.txt src/java/org/apache/hadoop/mapred/JobHistory.java

Author: ddas
Date: Tue Mar 25 03:41:37 2008
New Revision: 640764

URL: http://svn.apache.org/viewvc?rev=640764&view=rev
Log:
HADOOP-3080. Removes flush calls from JobHistory. Contributed by Amareshwari Sriramadasu.

Modified:
    hadoop/core/trunk/CHANGES.txt
    hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobHistory.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=640764&r1=640763&r2=640764&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Tue Mar 25 03:41:37 2008
@@ -349,6 +349,9 @@
     HADOOP-3040. If the input line starts with the separator char, the key
     is set as empty. (Amareshwari Sriramadasu via ddas) 
 
+    HADOOP-3080. Removes flush calls from JobHistory.
+    (Amareshwari Sriramadasu via ddas) 
+
 Release 0.16.2 - Unreleased
 
   BUG FIXES

Modified: hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobHistory.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobHistory.java?rev=640764&r1=640763&r2=640764&view=diff
==============================================================================
--- hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobHistory.java (original)
+++ hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobHistory.java Tue Mar 25 03:41:37 2008
@@ -206,7 +206,6 @@
   static void log(PrintWriter out, RecordTypes recordType, Keys key, 
                   String value){
     out.println(recordType.name() + DELIMITER + key + "=\"" + value + "\""); 
-    out.flush();
   }
   
   /**
@@ -231,7 +230,6 @@
     
     for (PrintWriter out : writers) {
       out.println(buf.toString());
-      out.flush();
     }
   }