You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zg...@apache.org on 2020/05/15 01:05:36 UTC
[hbase] branch branch-2.2 updated: HBASE-23702
hbase.hstore.flusher.count setting to 0 breaks HMaster (#1703)
This is an automated email from the ASF dual-hosted git repository.
zghao pushed a commit to branch branch-2.2
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.2 by this push:
new a6152af HBASE-23702 hbase.hstore.flusher.count setting to 0 breaks HMaster (#1703)
a6152af is described below
commit a6152af6cf3473e0a318960e6d2e90fc07f30d70
Author: Guanghao Zhang <zg...@apache.org>
AuthorDate: Fri May 15 09:05:25 2020 +0800
HBASE-23702 hbase.hstore.flusher.count setting to 0 breaks HMaster (#1703)
Co-authored-by: Ctest
Signed-off-by: Anoop Sam John <an...@gmail.com>
Signed-off-by: Wellington Chevreuil <wc...@apache.org>
---
.../java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
index 522d283..2e9db58 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
@@ -128,6 +128,11 @@ class MemStoreFlusher implements FlushRequester {
this.blockingWaitTime = conf.getInt("hbase.hstore.blockingWaitTime",
90000);
int handlerCount = conf.getInt("hbase.hstore.flusher.count", 2);
+ if (handlerCount < 1) {
+ LOG.warn("hbase.hstore.flusher.count was configed to {} which is less than 1, corrected to 1",
+ handlerCount);
+ handlerCount = 1;
+ }
this.flushHandlers = new FlushHandler[handlerCount];
LOG.info("globalMemStoreLimit="
+ TraditionalBinaryPrefix