From e5bbebc5071d9f9551dd53164d4ee56ea9157b57 Mon Sep 17 00:00:00 2001 From: Zhihong Yu Date: Fri, 29 Jul 2011 00:23:56 +0000 Subject: [PATCH] HBASE-4143 HTable.doPut(List) should check the writebuffer length every so often addendum by Gary H git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1152057 13f79535-47bb-0310-9956-ffa450edef68 --- src/main/java/org/apache/hadoop/hbase/client/HTable.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/apache/hadoop/hbase/client/HTable.java b/src/main/java/org/apache/hadoop/hbase/client/HTable.java index 874fa8a2588..5a486f6cc16 100644 --- a/src/main/java/org/apache/hadoop/hbase/client/HTable.java +++ b/src/main/java/org/apache/hadoop/hbase/client/HTable.java @@ -715,11 +715,8 @@ public class HTable implements HTableInterface, Closeable { // 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) {