svn commit: r1181412 - /hbase/branches/0.89/src/test/java/org/apache/hadoop/hbase/manual/utils/HdfsAppender.java

[nspiegelberg]

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
+}