svn commit: r611958 - in /lucene/hadoop/trunk: CHANGES.txt src/test/org/apache/hadoop/dfs/NNBench.java

[dhruba]

Author: dhruba
Date: Mon Jan 14 14:44:14 2008
New Revision: 611958

URL: http://svn.apache.org/viewvc?rev=611958&view=rev
Log:
HADOOP-2481. NNBench report its progress periodically.
(Hairong Kuang via dhruba)


Modified:
    lucene/hadoop/trunk/CHANGES.txt
    lucene/hadoop/trunk/src/test/org/apache/hadoop/dfs/NNBench.java

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=611958&r1=611957&r2=611958&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Mon Jan 14 14:44:14 2008
@@ -442,6 +442,9 @@
 
     HADOOP-2571. Suppress a suprious warning in test code. (cdouglas)
 
+    HADOOP-2481. NNBench report its progress periodically.
+    (Hairong Kuang via dhruba)
+
 Release 0.15.3 - (unreleased changes)
 
   BUG FIXES

Modified: lucene/hadoop/trunk/src/test/org/apache/hadoop/dfs/NNBench.java
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/test/org/apache/hadoop/dfs/NNBench.java?rev=611958&r1=611957&r2=611958&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/test/org/apache/hadoop/dfs/NNBench.java (original)
+++ lucene/hadoop/trunk/src/test/org/apache/hadoop/dfs/NNBench.java Mon Jan 14 
14:44:14 2008
@@ -770,6 +770,8 @@
             totalTimeAL2 += (System.currentTimeMillis() - startTimeAL);
             successfulOp = true;
             successfulFileOps ++;
+
+            reporter.setStatus("Finish "+ l + " files");
           } catch (IOException e) {
             TaskTracker.LOG.info("Exception recorded in op: " +
                     "Create/Write/Close");
@@ -811,6 +813,8 @@
             input.close();
             successfulOp = true;
             successfulFileOps ++;
+
+            reporter.setStatus("Finish "+ l + " files");
           } catch (IOException e) {
             TaskTracker.LOG.info("Exception recorded in op: OpenRead " + e);
             numOfExceptions++;
@@ -841,6 +845,8 @@
             
             successfulOp = true;
             successfulFileOps ++;
+
+            reporter.setStatus("Finish "+ l + " files");
           } catch (IOException e) {
             TaskTracker.LOG.info("Exception recorded in op: Rename");
 
@@ -870,6 +876,8 @@
             
             successfulOp = true;
             successfulFileOps ++;
+
+            reporter.setStatus("Finish "+ l + " files");
           } catch (IOException e) {
             TaskTracker.LOG.info("Exception in recorded op: Delete");