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:19:31 UTC
svn commit: r1364895 -
/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
Author: larsh
Date: Tue Jul 24 05:19:30 2012
New Revision: 1364895
URL: http://svn.apache.org/viewvc?rev=1364895&view=rev
Log:
HBASE-5659 Addendum
Modified:
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java?rev=1364895&r1=1364894&r2=1364895&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java Tue Jul 24 05:19:30 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();