svn commit: r1311031 - in /gora/trunk: CHANGES.txt gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java

[ferdy]

Author: ferdy
Date: Sun Apr  8 15:49:27 2012
New Revision: 1311031

URL: http://svn.apache.org/viewvc?rev=1311031&view=rev
Log:
GORA-115 Flushing HBaseStore should flush all HTable instances.

Modified:
    gora/trunk/CHANGES.txt
    
gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java

Modified: gora/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/gora/trunk/CHANGES.txt?rev=1311031&r1=1311030&r2=1311031&view=diff
==============================================================================
--- gora/trunk/CHANGES.txt (original)
+++ gora/trunk/CHANGES.txt Sun Apr  8 15:49:27 2012
@@ -5,6 +5,7 @@
 Gora Change Log
 
 0.2 Release:
+* GORA-115 Flushing HBaseStore should flush all HTable instances. (ferdy)
 
 * Make hbase autoflush default to false and make autoflush configurable rather 
than hardcoded (stack via lewismc)
 

Modified: 
gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
URL: 
http://svn.apache.org/viewvc/gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java?rev=1311031&r1=1311030&r2=1311031&view=diff
==============================================================================
--- 
gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
 (original)
+++ 
gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
 Sun Apr  8 15:49:27 2012
@@ -235,7 +235,9 @@ public class HBaseTableConnection implem
 
   @Override
   public void flushCommits() throws IOException {
-    getTable().flushCommits();
+    for (HTable table : pool) {
+      table.flushCommits();
+    }
   }
 
   @Override