Index: src/main/java/org/apache/hadoop/hbase/client/HTablePool.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/HTablePool.java (revision 1089730) +++ src/main/java/org/apache/hadoop/hbase/client/HTablePool.java (working copy) @@ -19,6 +19,7 @@ */ package org.apache.hadoop.hbase.client; +import java.io.IOException; import java.util.LinkedList; import java.util.Queue; import java.util.Map; @@ -117,6 +118,13 @@ * @param table table */ public void putTable(HTableInterface table) { + try { + if (!table.isAutoFlush()) { + table.flushCommits(); + } + } catch (IOException ioe) { + throw new RuntimeException(ioe); + } Queue queue = tables.get(Bytes.toString(table.getTableName())); if(queue.size() >= maxSize) return; queue.add(table);