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

[fe...@apache.org]

Author: ferdy
Date: Mon Jul  9 13:11:05 2012
New Revision: 1359146

URL: http://svn.apache.org/viewvc?rev=1359146&view=rev
Log:
GORA-147 fix threading issue caused by multiple threads trying to flush

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=1359146&r1=1359145&r2=1359146&view=diff
==============================================================================
--- gora/trunk/CHANGES.txt (original)
+++ gora/trunk/CHANGES.txt Mon Jul  9 13:11:05 2012
@@ -6,6 +6,8 @@ Gora Change Log
 
 0.3 (trunk) Current Development:
 
+* GORA-147 fix threading issue caused by multiple threads trying to flush (ferdy)
+
 * GORA-146 HBaseStore does not properly set endkey (ferdy)
 
 * GORA-140 Requires some adjustments on dependency at gora-cassandra (kazk, 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=1359146&r1=1359145&r2=1359146&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 Mon Jul  9 13:11:05 2012
@@ -78,7 +78,12 @@ public class HBaseTableConnection implem
   private HTable getTable() throws IOException {
     HTable table = tables.get();
     if (table == null) {
-      table = new HTable(conf, tableName);
+      table = new HTable(conf, tableName) {
+        @Override
+        public synchronized void flushCommits() throws IOException {
+          super.flushCommits();
+        }
+      };
       table.setAutoFlush(autoflush);
       pool.add(table); //keep track
       tables.set(table);