Author: tedyu
Date: Fri Jul 29 00:23:56 2011
New Revision: 1152057
URL: http://svn.apache.org/viewvc?rev=1152057&view=rev
Log:
HBASE-4143 HTable.doPut(List) should check the writebuffer length every so often
addendum by Gary H
Modified:
hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java
URL:
http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java?rev=1152057&r1=1152056&r2=1152057&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java
(original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java Fri
Jul 29 00:23:56 2011
@@ -715,11 +715,8 @@ public class HTable implements HTableInt
// we need to periodically see if the writebuffer is full instead of
waiting until the end of the List
n++;
- if (n == DOPUT_WB_CHECK) {
- if (autoFlush || currentWriteBufferSize > writeBufferSize) {
- flushCommits();
- n = 0;
- }
+ if (n % DOPUT_WB_CHECK == 0 && currentWriteBufferSize > writeBufferSize)
{
+ flushCommits();
}
}
if (autoFlush || currentWriteBufferSize > writeBufferSize) {
