HBASE-20542 ADDENDUM: test fix
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2d2d9957 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2d2d9957 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2d2d9957 Branch: refs/heads/HBASE-18477 Commit: 2d2d9957a7452073fbfc0b4a0624d302d0bc6a1c Parents: 0454878 Author: eshcar <esh...@oath.com> Authored: Tue Jul 3 14:01:00 2018 +0300 Committer: eshcar <esh...@oath.com> Committed: Tue Jul 3 14:01:00 2018 +0300 ---------------------------------------------------------------------- .../coprocessor/example/WriteHeavyIncrementObserverTestBase.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/2d2d9957/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/WriteHeavyIncrementObserverTestBase.java ---------------------------------------------------------------------- diff --git a/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/WriteHeavyIncrementObserverTestBase.java b/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/WriteHeavyIncrementObserverTestBase.java index 3583230..f9a5b5b 100644 --- a/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/WriteHeavyIncrementObserverTestBase.java +++ b/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/WriteHeavyIncrementObserverTestBase.java @@ -30,6 +30,7 @@ import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.Increment; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Table; +import org.apache.hadoop.hbase.regionserver.CompactingMemStore; import org.apache.hadoop.hbase.util.Bytes; import org.junit.AfterClass; import org.junit.BeforeClass; @@ -58,6 +59,8 @@ public class WriteHeavyIncrementObserverTestBase { public static void setUp() throws Exception { UTIL.getConfiguration().setLong(HConstants.HREGION_MEMSTORE_FLUSH_SIZE, 64 * 1024L); UTIL.getConfiguration().setLong("hbase.hregion.memstore.flush.size.limit", 1024L); + UTIL.getConfiguration().setDouble(CompactingMemStore.IN_MEMORY_FLUSH_THRESHOLD_FACTOR_KEY, + 0.014); UTIL.startMiniCluster(3); }
