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 {
|