You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by la...@apache.org on 2012/07/24 07:15:15 UTC
svn commit: r1364894 -
/hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
Author: larsh
Date: Tue Jul 24 05:15:15 2012
New Revision: 1364894
URL: http://svn.apache.org/viewvc?rev=1364894&view=rev
Log:
HBASE-5659 Addendum
Modified:
hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
Modified: hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java?rev=1364894&r1=1364893&r2=1364894&view=diff
==============================================================================
--- hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java (original)
+++ hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java Tue Jul 24 05:15:15 2012
@@ -276,6 +276,9 @@ public class TestAtomicOperation extends
synchronized(region) {
LOG.debug("flushing");
region.flushcache();
+ if (i%100==0) {
+ region.compactStores();
+ }
}
}
long ts = timeStamps.incrementAndGet();
@@ -361,6 +364,9 @@ public class TestAtomicOperation extends
synchronized(region) {
LOG.debug("flushing");
region.flushcache();
+ if (i%100==0) {
+ region.compactStores();
+ }
}
}
long ts = timeStamps.incrementAndGet();