You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ns...@apache.org on 2011/10/11 04:06:16 UTC
svn commit: r1181412 -
/hbase/branches/0.89/src/test/java/org/apache/hadoop/hbase/manual/utils/HdfsAppender.java
Author: nspiegelberg
Date: Tue Oct 11 02:06:15 2011
New Revision: 1181412
URL: http://svn.apache.org/viewvc?rev=1181412&view=rev
Log:
Fixed minor bug introduced right before checking in 172803
Modified:
hbase/branches/0.89/src/test/java/org/apache/hadoop/hbase/manual/utils/HdfsAppender.java
Modified: hbase/branches/0.89/src/test/java/org/apache/hadoop/hbase/manual/utils/HdfsAppender.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89/src/test/java/org/apache/hadoop/hbase/manual/utils/HdfsAppender.java?rev=1181412&r1=1181411&r2=1181412&view=diff
==============================================================================
--- hbase/branches/0.89/src/test/java/org/apache/hadoop/hbase/manual/utils/HdfsAppender.java (original)
+++ hbase/branches/0.89/src/test/java/org/apache/hadoop/hbase/manual/utils/HdfsAppender.java Tue Oct 11 02:06:15 2011
@@ -69,7 +69,7 @@ public class HdfsAppender extends Thread
Path p = new Path("/appendtest", Integer.toString(fileCount));
HLog.Writer writer = HLog.createWriter(fs, p, conf);
- while (writer.getLength() > logrollsize) {
+ while (writer.getLength() < logrollsize) {
int rSize = r.nextInt(maxSize-minSize) + minSize;
WALEdit value = new WALEdit();
value.add(new KeyValue(t, t, t, 0, new byte[rSize]));
@@ -94,4 +94,4 @@ public class HdfsAppender extends Thread
LOG.error("ioe encountered! stopping append thread", ioe);
}
}
-}
\ No newline at end of file
+}