hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yhema...@apache.org
Subject svn commit: r816589 - in /hadoop/mapreduce/trunk: CHANGES.txt src/java/org/apache/hadoop/mapred/JobQueueClient.java
Date Fri, 18 Sep 2009 11:52:29 GMT
Author: yhemanth
Date: Fri Sep 18 11:52:29 2009
New Revision: 816589

URL: http://svn.apache.org/viewvc?rev=816589&view=rev
Log:
Flushed writer in JobQueueClient so queue information is printed correctly. Contributed by
V.V. Chaitanya Krishna.

Modified:
    hadoop/mapreduce/trunk/CHANGES.txt
    hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueClient.java

Modified: hadoop/mapreduce/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=816589&r1=816588&r2=816589&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/CHANGES.txt (original)
+++ hadoop/mapreduce/trunk/CHANGES.txt Fri Sep 18 11:52:29 2009
@@ -658,3 +658,7 @@
 
     MAPREDUCE-645. Prevent distcp from running a job when the destination is a
     file, but the source is not. (Ravi Gummadi via cdouglas)
+
+    MAPREDUCE-1002. Flushed writer in JobQueueClient so queue information is
+    printed correctly. (V.V. Chaitanya Krishna via yhemanth)
+

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueClient.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueClient.java?rev=816589&r1=816588&r2=816589&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueClient.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueClient.java Fri Sep 18
11:52:29 2009
@@ -113,6 +113,7 @@
       throws IOException {
     if (jobQueueInfo == null) {
       writer.write("No queue found.\n");
+      writer.flush();
       return;
     }
     writer.write(String.format("Queue Name : %s \n",
@@ -134,6 +135,7 @@
       writer.write("\n");
     }
     writer.write(String.format("======================\n"));
+    writer.flush();
   }
   
   private void displayQueueList() throws IOException {



Mime
View raw message