You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by sy...@apache.org on 2016/02/02 06:49:41 UTC
[6/6] hbase git commit: HBASE-14969 Add throughput controller for
flush; ADDENDUM
HBASE-14969 Add throughput controller for flush; ADDENDUM
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/fc5e698c
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/fc5e698c
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/fc5e698c
Branch: refs/heads/hbase-12439
Commit: fc5e698c0a4e9613ab9eddcfc2a2684424806c56
Parents: 2cc48e0
Author: stack <st...@apache.org>
Authored: Mon Feb 1 08:08:07 2016 -0800
Committer: stack <st...@apache.org>
Committed: Mon Feb 1 08:08:39 2016 -0800
----------------------------------------------------------------------
.../throttle/TestFlushWithThroughputController.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/fc5e698c/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestFlushWithThroughputController.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestFlushWithThroughputController.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestFlushWithThroughputController.java
index 5d5be87..8908c71 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestFlushWithThroughputController.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestFlushWithThroughputController.java
@@ -168,9 +168,6 @@ public class TestFlushWithThroughputController {
conf.setInt(PressureAwareFlushThroughputController.HBASE_HSTORE_FLUSH_THROUGHPUT_TUNE_PERIOD,
3000);
TEST_UTIL.startMiniCluster(1);
- assertEquals(10L * 1024 * 1024,
- ((PressureAwareThroughputController) TEST_UTIL.getMiniHBaseCluster().getRegionServer(0)
- .getFlushThroughputController()).getMaxThroughput(), EPSILON);
Connection conn = ConnectionFactory.createConnection(conf);
try {
HTableDescriptor htd = new HTableDescriptor(tableName);
@@ -181,6 +178,12 @@ public class TestFlushWithThroughputController {
HRegionServer regionServer = TEST_UTIL.getRSForFirstRegionInTable(tableName);
PressureAwareFlushThroughputController throughputController =
(PressureAwareFlushThroughputController) regionServer.getFlushThroughputController();
+ for (Region region : regionServer.getOnlineRegions()) {
+ region.flush(true);
+ }
+ assertEquals(0.0, regionServer.getFlushPressure(), EPSILON);
+ Thread.sleep(5000);
+ assertEquals(10L * 1024 * 1024, throughputController.getMaxThroughput(), EPSILON);
Table table = conn.getTable(tableName);
Random rand = new Random();
for (int i = 0; i < 10; i++) {