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 dh...@apache.org on 2008/01/14 23:44:17 UTC
svn commit: r611958 - in /lucene/hadoop/trunk: CHANGES.txt
src/test/org/apache/hadoop/dfs/NNBench.java
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");