Added HBase cleanup code fix. closes brianfrankcooper#3

tjake · Apr 25, 2010 · ab55f7a · ab55f7a
1 parent 537c022
commit ab55f7a
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/com/yahoo/ycsb/db/HBaseClient.java b/src/com/yahoo/ycsb/db/HBaseClient.java
@@ -83,7 +83,13 @@ public void init() throws DBException
 	 */
     public void cleanup() throws DBException
     {
-
+        try {
+            if (_hTable != null) {
+                _hTable.flushCommits();
+            }
+        } catch (IOException e) {
+            throw new DBException(e);
+        }
     }
 
     public void getHTable(String table) throws IOException